You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by et...@apache.org on 2020/06/15 17:25:10 UTC
[storm] branch master updated: [STORM-3651] Give producerTasks in
ExecutorTransferMultiThreadingTest.testExecutorTransfer more time to finish
This is an automated email from the ASF dual-hosted git repository.
ethanli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git
The following commit(s) were added to refs/heads/master by this push:
new b56a1aa [STORM-3651] Give producerTasks in ExecutorTransferMultiThreadingTest.testExecutorTransfer more time to finish
new a9a747e Merge pull request #3286 from Ethanlm/STORM-3651
b56a1aa is described below
commit b56a1aafa4bf26f45f6633dacf1a0e7171c06b14
Author: Ethan Li <et...@gmail.com>
AuthorDate: Wed Jun 10 15:32:16 2020 -0500
[STORM-3651] Give producerTasks in ExecutorTransferMultiThreadingTest.testExecutorTransfer more time to finish
---
.../org/apache/storm/executor/ExecutorTransferMultiThreadingTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/storm-client/test/jvm/org/apache/storm/executor/ExecutorTransferMultiThreadingTest.java b/storm-client/test/jvm/org/apache/storm/executor/ExecutorTransferMultiThreadingTest.java
index 5dcb128..03240c8 100644
--- a/storm-client/test/jvm/org/apache/storm/executor/ExecutorTransferMultiThreadingTest.java
+++ b/storm-client/test/jvm/org/apache/storm/executor/ExecutorTransferMultiThreadingTest.java
@@ -126,7 +126,7 @@ public class ExecutorTransferMultiThreadingTest {
}
//give producers enough time to insert messages into the queue
- executorService.awaitTermination(100, TimeUnit.MILLISECONDS);
+ executorService.awaitTermination(1000, TimeUnit.MILLISECONDS);
//consume all the tuples in the queue and deserialize them one by one
//this mimics a remote worker.
@@ -134,6 +134,7 @@ public class ExecutorTransferMultiThreadingTest {
SingleThreadedConsumer consumer = new SingleThreadedConsumer(deserializer, producerTaskNum);
transferQueue.consume(consumer);
consumer.finalCheck();
+ executorService.shutdown();
}
private Runnable createProducerTask(ExecutorTransfer executorTransfer) {