You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by sn...@apache.org on 2019/06/26 00:01:06 UTC
[incubator-pinot] 01/01: initial
This is an automated email from the ASF dual-hosted git repository.
snlee pushed a commit to branch increase-wait-time
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
commit 09e87203dae8b154b7b3f4f3064d197e4bd105d1
Author: Seunghyun Lee <sn...@linkedin.com>
AuthorDate: Tue Jun 25 17:00:21 2019 -0700
initial
---
.../integration/tests/ControllerPeriodicTasksIntegrationTests.java | 2 +-
.../tests/HadoopSegmentBuildPushOfflineClusterIntegrationTest.java | 2 +-
.../apache/pinot/integration/tests/HybridClusterIntegrationTest.java | 2 +-
.../tests/HybridClusterIntegrationTestCommandLineRunner.java | 2 +-
.../MetadataAndDictionaryAggregationPlanClusterIntegrationTest.java | 4 ++--
.../apache/pinot/integration/tests/OfflineClusterIntegrationTest.java | 2 +-
.../pinot/integration/tests/RealtimeClusterIntegrationTest.java | 2 +-
.../pinot/integration/tests/StarTreeClusterIntegrationTest.java | 4 ++--
8 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/ControllerPeriodicTasksIntegrationTests.java b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/ControllerPeriodicTasksIntegrationTests.java
index 8c9ffe5..a1d750b 100644
--- a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/ControllerPeriodicTasksIntegrationTests.java
+++ b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/ControllerPeriodicTasksIntegrationTests.java
@@ -193,7 +193,7 @@ public class ControllerPeriodicTasksIntegrationTests extends BaseClusterIntegrat
executor.shutdown();
executor.awaitTermination(10, TimeUnit.MINUTES);
uploadSegments(_tarDir);
- waitForAllDocsLoaded(600_000L);
+ waitForAllDocsLoaded(900_000L);
}
/**
diff --git a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/HadoopSegmentBuildPushOfflineClusterIntegrationTest.java b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/HadoopSegmentBuildPushOfflineClusterIntegrationTest.java
index 36e083c..aca7f4a 100644
--- a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/HadoopSegmentBuildPushOfflineClusterIntegrationTest.java
+++ b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/HadoopSegmentBuildPushOfflineClusterIntegrationTest.java
@@ -99,7 +99,7 @@ public class HadoopSegmentBuildPushOfflineClusterIntegrationTest extends BaseClu
generateAndPushSegmentsFromHadoop();
// Wait for all documents loaded
- waitForAllDocsLoaded(600_000L);
+ waitForAllDocsLoaded(900_000L);
}
@AfterClass
diff --git a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/HybridClusterIntegrationTest.java b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/HybridClusterIntegrationTest.java
index f9ca74a..b1d06a5 100644
--- a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/HybridClusterIntegrationTest.java
+++ b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/HybridClusterIntegrationTest.java
@@ -100,7 +100,7 @@ public class HybridClusterIntegrationTest extends BaseClusterIntegrationTestSet
uploadSegments(_tarDir);
// Wait for all documents loaded
- waitForAllDocsLoaded(600_000L);
+ waitForAllDocsLoaded(900_000L);
}
protected void startHybridCluster()
diff --git a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/HybridClusterIntegrationTestCommandLineRunner.java b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/HybridClusterIntegrationTestCommandLineRunner.java
index 6e5474f..ee5cc58 100644
--- a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/HybridClusterIntegrationTestCommandLineRunner.java
+++ b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/HybridClusterIntegrationTestCommandLineRunner.java
@@ -324,7 +324,7 @@ public class HybridClusterIntegrationTestCommandLineRunner {
responseFileReader.mark(4096);
_countStarResult = JsonUtils.stringToJsonNode(responseFileReader.readLine()).get("totalDocs").asLong();
responseFileReader.reset();
- waitForAllDocsLoaded(600_000L);
+ waitForAllDocsLoaded(900_000L);
// Run queries in multiple threads
ExecutorService executorService =
diff --git a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/MetadataAndDictionaryAggregationPlanClusterIntegrationTest.java b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/MetadataAndDictionaryAggregationPlanClusterIntegrationTest.java
index 61dc1b7..4c27240 100644
--- a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/MetadataAndDictionaryAggregationPlanClusterIntegrationTest.java
+++ b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/MetadataAndDictionaryAggregationPlanClusterIntegrationTest.java
@@ -113,9 +113,9 @@ public class MetadataAndDictionaryAggregationPlanClusterIntegrationTest extends
loadDataIntoH2(avroFiles);
// Wait for all documents loaded
- waitForAllDocsLoaded(600_000L);
+ waitForAllDocsLoaded(900_000L);
_currentTable = STAR_TREE_TABLE_NAME;
- waitForAllDocsLoaded(600_000L);
+ waitForAllDocsLoaded(900_000L);
}
private void loadDataIntoH2(List<File> avroFiles)
diff --git a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/OfflineClusterIntegrationTest.java b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/OfflineClusterIntegrationTest.java
index 8d9d144..6e1f9b5 100644
--- a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/OfflineClusterIntegrationTest.java
+++ b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/OfflineClusterIntegrationTest.java
@@ -133,7 +133,7 @@ public class OfflineClusterIntegrationTest extends BaseClusterIntegrationTestSet
registerCallbackHandlers();
// Wait for all documents loaded
- waitForAllDocsLoaded(600_000L);
+ waitForAllDocsLoaded(900_000L);
}
private void registerCallbackHandlers() {
diff --git a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/RealtimeClusterIntegrationTest.java b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/RealtimeClusterIntegrationTest.java
index d5196bf..2e467be 100644
--- a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/RealtimeClusterIntegrationTest.java
+++ b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/RealtimeClusterIntegrationTest.java
@@ -74,7 +74,7 @@ public class RealtimeClusterIntegrationTest extends BaseClusterIntegrationTestSe
setUpTable(avroFiles.get(0));
// Wait for all documents loaded
- waitForAllDocsLoaded(600_000L);
+ waitForAllDocsLoaded(900_000L);
}
protected void setUpTable(File avroFile)
diff --git a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/StarTreeClusterIntegrationTest.java b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/StarTreeClusterIntegrationTest.java
index 06ea600..a72ad9f 100644
--- a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/StarTreeClusterIntegrationTest.java
+++ b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/StarTreeClusterIntegrationTest.java
@@ -101,9 +101,9 @@ public class StarTreeClusterIntegrationTest extends BaseClusterIntegrationTest {
// Wait for all documents loaded
_currentTable = DEFAULT_TABLE_NAME;
- waitForAllDocsLoaded(600_000L);
+ waitForAllDocsLoaded(900_000L);
_currentTable = STAR_TREE_TABLE_NAME;
- waitForAllDocsLoaded(600_000L);
+ waitForAllDocsLoaded(900_000L);
}
protected void setUpSegmentsAndQueryGenerator()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org