This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 2b12cbdf48 Fixes Integration test (#15699)
2b12cbdf48 is described below
commit 2b12cbdf4892f7e8402a180e7f456e4a7eac7920
Author: NOOB <[email protected]>
AuthorDate: Fri May 2 23:40:50 2025 +0530
Fixes Integration test (#15699)
---
.../apache/pinot/integration/tests/BaseDedupIntegrationTest.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
diff --git
a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/BaseDedupIntegrationTest.java
b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/BaseDedupIntegrationTest.java
index 88f1f07ddf..56a0aea157 100644
---
a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/BaseDedupIntegrationTest.java
+++
b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/BaseDedupIntegrationTest.java
@@ -24,6 +24,7 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.commons.io.FileUtils;
+import org.apache.pinot.common.utils.PauselessConsumptionUtils;
import org.apache.pinot.controller.helix.ControllerTest;
import org.apache.pinot.spi.config.table.ColumnPartitionConfig;
import org.apache.pinot.spi.config.table.DedupConfig;
@@ -36,6 +37,7 @@ import
org.apache.pinot.spi.config.table.ingestion.IngestionConfig;
import
org.apache.pinot.spi.config.table.ingestion.ParallelSegmentConsumptionPolicy;
import org.apache.pinot.spi.config.table.ingestion.StreamIngestionConfig;
import org.apache.pinot.spi.data.Schema;
+import org.apache.pinot.spi.utils.CommonConstants;
import org.apache.pinot.spi.utils.Enablement;
import org.apache.pinot.spi.utils.StringUtil;
import org.apache.pinot.spi.utils.builder.TableConfigBuilder;
@@ -113,7 +115,7 @@ public class BaseDedupIntegrationTest extends
BaseClusterIntegrationTestSet {
DedupConfig dedupConfig = new DedupConfig();
dedupConfig.setMetadataTTL(30);
dedupConfig.setPreload(Enablement.ENABLE);
- return new
TableConfigBuilder(TableType.REALTIME).setTableName("DedupTableWithReplicas_REALTIME")
+ TableConfig tableConfig = new
TableConfigBuilder(TableType.REALTIME).setTableName("DedupTableWithReplicas_REALTIME")
.setTimeColumnName(getTimeColumnName())
.setFieldConfigList(getFieldConfigs())
.setNumReplicas(2)
@@ -130,6 +132,10 @@ public class BaseDedupIntegrationTest extends
BaseClusterIntegrationTestSet {
.setReplicaGroupStrategyConfig(new
ReplicaGroupStrategyConfig(primaryKeyColumn, 2))
.setDedupConfig(dedupConfig)
.build();
+ if (PauselessConsumptionUtils.isPauselessEnabled(tableConfig)) {
+
tableConfig.getValidationConfig().setPeerSegmentDownloadScheme(CommonConstants.HTTP_PROTOCOL);
+ }
+ return tableConfig;
}
@AfterClass
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
