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 8f8825805470c8b1ae3ede5d5c2b96f95b1aec9f Author: Viraj Jasani <[email protected]> AuthorDate: Mon Mar 16 11:06:28 2026 -0700 ignore test - too aggressive for jenkins builds --- .../apache/phoenix/end2end/ConcurrentMutationsExtendedIndexIT.java | 2 ++ .../phoenix/end2end/ConcurrentMutationsLazyPostBatchWriteIT.java | 5 +++++ 2 files changed, 7 insertions(+) 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())); }
