This is an automated email from the ASF dual-hosted git repository. vjasani pushed a commit to branch tmp-ec in repository https://gitbox.apache.org/repos/asf/phoenix.git
commit 7f8074c4dad348a59bf5e0bb70ce7c95e5878c71 Author: Viraj Jasani <[email protected]> AuthorDate: Mon Mar 16 11:06:28 2026 -0700 ignore test - too aggressive for jenkins builds --- .../main/java/org/apache/phoenix/hbase/index/IndexCDCConsumer.java | 4 ++-- .../apache/phoenix/end2end/ConcurrentMutationsExtendedIndexIT.java | 2 ++ .../phoenix/end2end/ConcurrentMutationsLazyPostBatchWriteIT.java | 5 +++++ 3 files changed, 9 insertions(+), 2 deletions(-) diff --git a/phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/IndexCDCConsumer.java b/phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/IndexCDCConsumer.java index 2fd66bae54..68bfbd6d7f 100644 --- a/phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/IndexCDCConsumer.java +++ b/phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/IndexCDCConsumer.java @@ -97,7 +97,7 @@ public class IndexCDCConsumer implements Runnable { public static final String INDEX_CDC_CONSUMER_BATCH_SIZE = "phoenix.index.cdc.consumer.batch.size"; - private static final int DEFAULT_CDC_BATCH_SIZE = 1000; + private static final int DEFAULT_CDC_BATCH_SIZE = 100; public static final String INDEX_CDC_CONSUMER_STARTUP_DELAY_MS = "phoenix.index.cdc.consumer.startup.delay.ms"; @@ -116,7 +116,7 @@ public class IndexCDCConsumer implements Runnable { */ public static final String INDEX_CDC_CONSUMER_TIMESTAMP_BUFFER_MS = "phoenix.index.cdc.consumer.timestamp.buffer.ms"; - private static final long DEFAULT_TIMESTAMP_BUFFER_MS = 25000; + private static final long DEFAULT_TIMESTAMP_BUFFER_MS = 10000; /** * Maximum number of retries when CDC events exist but the corresponding data table mutations are diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsExtendedIndexIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsExtendedIndexIT.java index 531e036a9c..a04e48e1d5 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsExtendedIndexIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsExtendedIndexIT.java @@ -37,6 +37,7 @@ import org.apache.phoenix.util.EnvironmentEdgeManager; import org.apache.phoenix.util.TestUtil; import org.junit.Assume; import org.junit.BeforeClass; +import org.junit.Ignore; import org.junit.Test; import org.junit.runner.RunWith; import org.junit.runners.Parameterized; @@ -172,6 +173,7 @@ public abstract class ConcurrentMutationsExtendedIndexIT extends ParallelStatsDi // This test is heavy and it might exhaust jenkins resources @Test(timeout = 1800000) + @Ignore("too aggressive for jenkins builds") public void testConcurrentUpsertsWithTableSplitsMerges() throws Exception { Assume.assumeFalse(uncovered); int nThreads = 13; diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsLazyPostBatchWriteIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsLazyPostBatchWriteIT.java index a6ecfa7e60..09d2da7d67 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsLazyPostBatchWriteIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsLazyPostBatchWriteIT.java @@ -29,6 +29,9 @@ import org.junit.experimental.categories.Category; import org.apache.phoenix.thirdparty.com.google.common.collect.Maps; +import static org.apache.phoenix.hbase.index.IndexCDCConsumer.INDEX_CDC_CONSUMER_BATCH_SIZE; +import static org.apache.phoenix.hbase.index.IndexCDCConsumer.INDEX_CDC_CONSUMER_TIMESTAMP_BUFFER_MS; + /** * Test class that extends ConcurrentMutationsExtendedIT with lazy post batch write enabled. */ @@ -51,6 +54,8 @@ public class ConcurrentMutationsLazyPostBatchWriteIT extends ConcurrentMutations props.put("phoenix.index.concurrent.wait.duration.ms", "10"); props.put(QueryServices.TASK_HANDLING_INTERVAL_MS_ATTRIB, Long.toString(2)); props.put(QueryServices.TASK_HANDLING_INITIAL_DELAY_MS_ATTRIB, Long.toString(1)); + props.put(INDEX_CDC_CONSUMER_BATCH_SIZE, Integer.toString(4500)); + props.put(INDEX_CDC_CONSUMER_TIMESTAMP_BUFFER_MS, Integer.toString(2500)); props.put("hbase.coprocessor.master.classes", PhoenixMasterObserver.class.getName()); setUpTestDriver(new ReadOnlyProps(props.entrySet().iterator())); }
