PHOENIX-7211 : Identify IT tests that can be run successfully against real distributed cluster

BUILDING.md

@@ -136,6 +136,14 @@ Note that the dependency check report generation is only enabled when run on Jav
 The reports are accessible via `target/site/index.html`, under the main project,
 as well as each of the subprojects. (not every project has all reports)
 
+Running tests on local cluster
+-----------------------
+
+Run IT tests part of a defined execution goal in pom.xml (e.g SignOffTests)
+`$ mvn failsafe:integration-test@SignOffTests failsafe:verify@SignOffTests -Dhbase.profile=2.5
+-Dskip.code-coverage -Dmaven.test.failure.ignore=true -Dhbase.test.cluster.distributed=true
+-Dhbase.zookeeper.quorum=localhost -Dhbase.zookeeper.property.clientPort=2181`
+
 Generate Apache Web Site
 ------------------------
 

phoenix-core/src/it/java/org/apache/phoenix/end2end/AbsFunctionEnd2EndIT.java

@@ -35,7 +35,7 @@
 /**
  * End to end tests for {@link AbsFunction}
  */
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class AbsFunctionEnd2EndIT extends ParallelStatsDisabledIT {
 
     private static final String TABLE_NAME = generateUniqueName();

phoenix-core/src/it/java/org/apache/phoenix/end2end/AggregateIT.java

@@ -39,7 +39,7 @@
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class})
 public class AggregateIT extends BaseAggregateIT {
 
     @Test

phoenix-core/src/it/java/org/apache/phoenix/end2end/AggregateQueryIT.java

@@ -48,7 +48,7 @@
 import org.junit.experimental.categories.Category;
 import org.junit.runners.Parameterized.Parameters;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class AggregateQueryIT extends BaseQueryIT {
 
     @Parameters(name="AggregateQueryIT_{index}") // name is used by failsafe as file name in reports

phoenix-core/src/it/java/org/apache/phoenix/end2end/AggregateQueryWithRegionMoves2IT.java

@@ -38,7 +38,7 @@
 import java.util.HashMap;
 import java.util.Map;
 
-@Category(NeedsOwnMiniClusterTest.class)
+@Category({NeedsOwnMiniClusterTest.class, SupportsDistributedClusterTest.class})
 public class AggregateQueryWithRegionMoves2IT extends AggregateQueryWithRegionMovesIT {
 
     private static final Logger LOGGER =

phoenix-core/src/it/java/org/apache/phoenix/end2end/AggregateQueryWithRegionMovesIT.java

@@ -51,7 +51,7 @@
 import static org.junit.Assert.assertNull;
 import static org.junit.Assert.assertTrue;
 
-@Category(NeedsOwnMiniClusterTest.class)
+@Category({NeedsOwnMiniClusterTest.class, SupportsDistributedClusterTest.class})
 public class AggregateQueryWithRegionMovesIT extends BaseQueryWithRegionMovesIT {
 
     @Parameters(name = "AggregateQueryWithRegionMovesIT_{index}")

phoenix-core/src/it/java/org/apache/phoenix/end2end/AggregateWithRegionMoves2IT.java

@@ -36,7 +36,7 @@
 import java.util.HashMap;
 import java.util.Map;
 
-@Category(NeedsOwnMiniClusterTest.class)
+@Category({NeedsOwnMiniClusterTest.class, SupportsDistributedClusterTest.class})
 public class AggregateWithRegionMoves2IT extends AggregateWithRegionMovesIT {
 
     private static final Logger LOGGER =

phoenix-core/src/it/java/org/apache/phoenix/end2end/AggregateWithRegionMovesIT.java

@@ -40,7 +40,7 @@
 import static org.junit.Assert.assertTrue;
 import static org.junit.Assert.fail;
 
-@Category(NeedsOwnMiniClusterTest.class)
+@Category({NeedsOwnMiniClusterTest.class})
 public class AggregateWithRegionMovesIT extends BaseAggregateWithRegionMovesIT {
 
     @Before

phoenix-core/src/it/java/org/apache/phoenix/end2end/AlterAddCascadeIndexIT.java

@@ -58,7 +58,7 @@
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertTrue;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 @RunWith(Parameterized.class)
 public class AlterAddCascadeIndexIT extends ParallelStatsDisabledIT {
 

phoenix-core/src/it/java/org/apache/phoenix/end2end/AlterSessionIT.java

@@ -41,7 +41,7 @@
  * Basic tests for Alter Session Statements
  *
  */
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class AlterSessionIT extends ParallelStatsDisabledIT {
 
     private String tableName;

phoenix-core/src/it/java/org/apache/phoenix/end2end/AlterTableIT.java

@@ -99,7 +99,7 @@
  * or at the end of test class.
  *
  */
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class})
 @RunWith(Parameterized.class)
 public class AlterTableIT extends ParallelStatsDisabledIT {
     private String schemaName;

phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java

@@ -63,7 +63,7 @@
 import org.mockito.AdditionalMatchers;
 import org.mockito.Mockito;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class AppendOnlySchemaIT extends ParallelStatsDisabledIT {
 
 

phoenix-core/src/it/java/org/apache/phoenix/end2end/ArithmeticQueryIT.java

@@ -40,7 +40,7 @@
 import org.apache.phoenix.thirdparty.com.google.common.primitives.Floats;
 
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class ArithmeticQueryIT extends ParallelStatsDisabledIT {
 
     @Test

phoenix-core/src/it/java/org/apache/phoenix/end2end/Array1IT.java

@@ -43,7 +43,7 @@
 import org.junit.experimental.categories.Category;
 import org.apache.phoenix.thirdparty.com.google.common.primitives.Floats;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class Array1IT extends ArrayIT {
     private void assertArrayGetString(ResultSet rs, int arrayIndex, Array expectedArray, String expectedString)
             throws SQLException {

phoenix-core/src/it/java/org/apache/phoenix/end2end/Array2IT.java

@@ -41,7 +41,7 @@
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class Array2IT extends ArrayIT {
 
     private static final String TEST_QUERY = "select ?[2] from \"SYSTEM\".\"CATALOG\" limit 1";

phoenix-core/src/it/java/org/apache/phoenix/end2end/Array3IT.java

@@ -34,7 +34,7 @@
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class Array3IT extends ArrayIT {
 
     @Test

phoenix-core/src/it/java/org/apache/phoenix/end2end/ArrayAppendFunctionIT.java

@@ -32,7 +32,7 @@
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class ArrayAppendFunctionIT extends ParallelStatsDisabledIT {
     private String initTables(Connection conn) throws Exception {
         String tableName = generateUniqueName();

phoenix-core/src/it/java/org/apache/phoenix/end2end/ArrayConcatFunctionIT.java

@@ -32,7 +32,7 @@
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class ArrayConcatFunctionIT extends ParallelStatsDisabledIT {
 
     private String initTables(Connection conn) throws Exception {

phoenix-core/src/it/java/org/apache/phoenix/end2end/ArrayFillFunctionIT.java

@@ -36,7 +36,7 @@
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class ArrayFillFunctionIT extends ParallelStatsDisabledIT {
 
     private String tableName;

phoenix-core/src/it/java/org/apache/phoenix/end2end/ArrayPrependFunctionIT.java

@@ -28,7 +28,7 @@
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class ArrayPrependFunctionIT extends ParallelStatsDisabledIT {
 
     private void initTableWithVarArray(Connection conn, String tableName, String type, Object[] objectArray, String value) throws SQLException {

phoenix-core/src/it/java/org/apache/phoenix/end2end/ArrayRemoveFunctionIT.java

@@ -32,7 +32,7 @@
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class ArrayRemoveFunctionIT extends ParallelStatsDisabledIT {
 
 	private Connection conn;

phoenix-core/src/it/java/org/apache/phoenix/end2end/ArrayToStringFunctionIT.java

@@ -30,7 +30,7 @@
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class ArrayToStringFunctionIT extends ParallelStatsDisabledIT {
     private String tableName;
     private Connection conn;

phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java

@@ -27,7 +27,7 @@
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class ArraysWithNullsIT extends ParallelStatsDisabledIT {
 
     @Test

phoenix-core/src/it/java/org/apache/phoenix/end2end/AuditLoggingIT.java

@@ -31,7 +31,7 @@
 import static org.junit.Assert.assertTrue;
 import static org.junit.Assert.assertEquals;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class})
 public class AuditLoggingIT extends ParallelStatsDisabledIT {
 
     @Test

phoenix-core/src/it/java/org/apache/phoenix/end2end/AutoCommitIT.java

@@ -33,7 +33,7 @@
 import org.junit.experimental.categories.Category;
 
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class AutoCommitIT extends ParallelStatsDisabledIT {
 
     @Test

phoenix-core/src/it/java/org/apache/phoenix/end2end/AutoPartitionViewsIT.java

@@ -47,7 +47,7 @@
 import org.junit.runners.Parameterized;
 import org.junit.runners.Parameterized.Parameters;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 @RunWith(Parameterized.class)
 public class AutoPartitionViewsIT extends ParallelStatsDisabledIT {
 

phoenix-core/src/it/java/org/apache/phoenix/end2end/BackwardCompatibilityIT.java

@@ -88,7 +88,7 @@
  */
 
 @RunWith(Parameterized.class)
-@Category(NeedsOwnMiniClusterTest.class)
+@Category({NeedsOwnMiniClusterTest.class, SupportsDistributedClusterTest.class})
 public class BackwardCompatibilityIT {
 
     private static final Logger LOGGER = LoggerFactory.getLogger(

phoenix-core/src/it/java/org/apache/phoenix/end2end/BaseAggregateWithRegionMoves2IT.java

@@ -49,7 +49,7 @@
 import static org.junit.Assert.assertNull;
 import static org.junit.Assert.assertTrue;
 
-@Category(NeedsOwnMiniClusterTest.class)
+@Category({NeedsOwnMiniClusterTest.class, SupportsDistributedClusterTest.class})
 public class BaseAggregateWithRegionMoves2IT extends ParallelStatsDisabledWithRegionMovesIT {
 
     @Before

phoenix-core/src/it/java/org/apache/phoenix/end2end/BaseAggregateWithRegionMoves3IT.java

@@ -36,7 +36,7 @@
 import java.util.HashMap;
 import java.util.Map;
 
-@Category(NeedsOwnMiniClusterTest.class)
+@Category({NeedsOwnMiniClusterTest.class, SupportsDistributedClusterTest.class})
 public class BaseAggregateWithRegionMoves3IT extends BaseAggregateWithRegionMoves2IT {
 
     private static final Logger LOGGER =

phoenix-core/src/it/java/org/apache/phoenix/end2end/BaseAggregateWithRegionMoves4IT.java

@@ -42,7 +42,7 @@
 
 import static org.apache.phoenix.util.TestUtil.TEST_PROPERTIES;
 
-@Category(NeedsOwnMiniClusterTest.class)
+@Category({NeedsOwnMiniClusterTest.class, SupportsDistributedClusterTest.class})
 public class BaseAggregateWithRegionMoves4IT extends BaseAggregateWithRegionMoves2IT {
 
     private static final Logger LOGGER =

phoenix-core/src/it/java/org/apache/phoenix/end2end/BaseViewIT.java

@@ -53,7 +53,7 @@
 import org.junit.runners.Parameterized;
 import org.junit.runners.Parameterized.Parameters;
 
-@Category(ParallelStatsEnabledTest.class)
+@Category({ParallelStatsEnabledTest.class})
 @RunWith(Parameterized.class)
 public abstract class BaseViewIT extends ParallelStatsEnabledIT {
 

phoenix-core/src/it/java/org/apache/phoenix/end2end/BinaryRowKeyIT.java

@@ -35,7 +35,7 @@
 import org.junit.experimental.categories.Category;
 
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class BinaryRowKeyIT extends ParallelStatsDisabledIT {
 
     private static void initTableValues(String tableName) throws SQLException {

phoenix-core/src/it/java/org/apache/phoenix/end2end/BinaryStringLiteralIT.java

@@ -27,7 +27,7 @@
 /**
  * End to end tests for Hexadecimal and Binary literals
  */
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class BinaryStringLiteralIT extends ParallelStatsDisabledIT {
 
     private static String EMPTY = "";

phoenix-core/src/it/java/org/apache/phoenix/end2end/CSVCommonsLoaderIT.java

@@ -51,7 +51,7 @@
 import org.junit.experimental.categories.Category;
 import org.junit.rules.TemporaryFolder;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class CSVCommonsLoaderIT extends ParallelStatsDisabledIT {
 
     private static final String DATATYPE_TABLE = "DATATYPE";

phoenix-core/src/it/java/org/apache/phoenix/end2end/CaseStatementIT.java

@@ -53,7 +53,7 @@
 
 import org.apache.phoenix.thirdparty.com.google.common.collect.Lists;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 @RunWith(Parameterized.class)
 @FixMethodOrder(MethodSorters.NAME_ASCENDING)
 public class CaseStatementIT extends BaseQueryIT {

phoenix-core/src/it/java/org/apache/phoenix/end2end/CastAndCoerceIT.java

@@ -40,7 +40,7 @@
 import org.junit.runners.Parameterized;
 import org.junit.runners.Parameterized.Parameters;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 @RunWith(Parameterized.class)
 public class CastAndCoerceIT extends BaseQueryIT {
 

phoenix-core/src/it/java/org/apache/phoenix/end2end/CbrtFunctionEnd2EndIT.java

@@ -34,7 +34,7 @@
 /**
  * End to end tests for {@link CbrtFunction}
  */
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class CbrtFunctionEnd2EndIT extends ParallelStatsDisabledIT {
 
     private static final String KEY = "key";

phoenix-core/src/it/java/org/apache/phoenix/end2end/ClientHashAggregateIT.java

@@ -34,7 +34,9 @@
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
+//@Category(ParallelStatsDisabledTest.class)
+
 public class ClientHashAggregateIT extends ParallelStatsDisabledIT {
 
     @Test

phoenix-core/src/it/java/org/apache/phoenix/end2end/CoalesceFunctionIT.java

@@ -46,7 +46,7 @@
 import org.junit.experimental.categories.Category;
 
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class CoalesceFunctionIT extends ParallelStatsDisabledIT {
 
     @Test

phoenix-core/src/it/java/org/apache/phoenix/end2end/CollationKeyFunctionIT.java

@@ -35,7 +35,7 @@
  * End2End test that tests the COLLATION_KEY in an ORDER BY clause
  * 
  */
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class CollationKeyFunctionIT extends ParallelStatsDisabledIT {
 
 	private String tableName;

phoenix-core/src/it/java/org/apache/phoenix/end2end/ColumnEncodedBytesPropIT.java

@@ -45,7 +45,7 @@
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class ColumnEncodedBytesPropIT extends ParallelStatsDisabledIT {
 
 	private String generateColsDDL(int numCols) {

phoenix-core/src/it/java/org/apache/phoenix/end2end/ColumnProjectionOptimizationIT.java

@@ -60,7 +60,7 @@
 import org.junit.experimental.categories.Category;
 
 
-@Category(ParallelStatsDisabledTest.class)
+@Category({ParallelStatsDisabledTest.class, SupportsDistributedClusterTest.class})
 public class ColumnProjectionOptimizationIT extends ParallelStatsDisabledIT {
 
     @Test

phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsExtendedIT.java

@@ -59,7 +59,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-@Category(NeedsOwnMiniClusterTest.class)
+@Category({NeedsOwnMiniClusterTest.class})
 @RunWith(Parameterized.class)
 public class ConcurrentMutationsExtendedIT extends ParallelStatsDisabledIT {
     private static final Logger LOGGER =