This is an automated email from the ASF dual-hosted git repository.

yanxinyi pushed a commit to branch revert-1067-PHOENIX-6302-master
in repository https://gitbox.apache.org/repos/asf/phoenix.git

commit 78ed2304158ea45e78fc9a7cc23fe3daeff4044b
Author: Xinyi Yan <yanxi...@gmail.com>
AuthorDate: Wed Jan 6 09:27:22 2021 -0800

    Revert "PHOENIX-6302 : De-flake ConcurrentUpsertsWithoutIndexedColsIT"
---
 .../ConcurrentUpsertsWithoutIndexedColsIT.java      | 21 +++------------------
 1 file changed, 3 insertions(+), 18 deletions(-)

diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentUpsertsWithoutIndexedColsIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentUpsertsWithoutIndexedColsIT.java
index d728b29..bec7e28 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentUpsertsWithoutIndexedColsIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentUpsertsWithoutIndexedColsIT.java
@@ -19,14 +19,10 @@
 package org.apache.phoenix.end2end;
 
 import 
org.apache.hbase.thirdparty.com.google.common.util.concurrent.ThreadFactoryBuilder;
-import 
org.apache.phoenix.compat.hbase.coprocessor.CompatBaseScannerRegionObserver;
-import org.apache.phoenix.query.QueryServices;
-import org.apache.phoenix.thirdparty.com.google.common.collect.ImmutableMap;
-import org.apache.phoenix.util.ReadOnlyProps;
 import org.apache.phoenix.util.RunUntilFailure;
 import org.apache.phoenix.util.TestUtil;
-import org.junit.BeforeClass;
 import org.junit.Test;
+import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -34,7 +30,6 @@ import org.slf4j.LoggerFactory;
 import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.SQLException;
-import java.util.Map;
 import java.util.Random;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.ExecutorService;
@@ -47,24 +42,14 @@ import static org.junit.Assert.assertTrue;
 
 
 @RunWith(RunUntilFailure.class)
+@Category(NeedsOwnMiniClusterTest.class)
 public class ConcurrentUpsertsWithoutIndexedColsIT
-        extends BaseUniqueNamesOwnClusterIT {
+        extends ParallelStatsDisabledIT {
 
     private static final Random RANDOM = new Random(5);
     private static final Logger LOGGER =
         LoggerFactory.getLogger(ConcurrentUpsertsWithoutIndexedColsIT.class);
 
-    private static final Map<String, String> PROPS = ImmutableMap.of(
-        QueryServices.GLOBAL_INDEX_ROW_AGE_THRESHOLD_TO_DELETE_MS_ATTRIB,
-        Long.toString(0),
-        CompatBaseScannerRegionObserver.PHOENIX_MAX_LOOKBACK_AGE_CONF_KEY,
-        Integer.toString(1000000));
-
-    @BeforeClass
-    public static synchronized void doSetup() throws Exception {
-        setUpTestDriver(new ReadOnlyProps(PROPS.entrySet().iterator()));
-    }
-
     @Test
     public void testConcurrentUpsertsWithoutIndexedColumns() throws Exception {
         int nThreads = 4;

Reply via email to