(pinot) branch master updated: Fixes Integration test (#15699)

[jackie]

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 <43700604+noob-se...@users.noreply.github.com>
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: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org