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:52:27 UTC
[storm] branch 2.2.x-branch 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 2.2.x-branch
in repository https://gitbox.apache.org/repos/asf/storm.git
The following commit(s) were added to refs/heads/2.2.x-branch by this push:
new 3d969c4 [STORM-3651] Give producerTasks in ExecutorTransferMultiThreadingTest.testExecutorTransfer more time to finish
3d969c4 is described below
commit 3d969c4d63be9fe2759f44af609d5d7a88d6a30a
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 6e8a5d2..91212d1 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) {