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:05 UTC
[incubator-pinot] branch increase-wait-time created (now 09e8720)
This is an automated email from the ASF dual-hosted git repository.
snlee pushed a change to branch increase-wait-time
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
at 09e8720 initial
This branch includes the following new commits:
new 09e8720 initial
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org
[incubator-pinot] 01/01: initial
Posted by sn...@apache.org.
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