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/10 19:57:39 UTC
[storm] branch 2.2.x-branch updated: [STORM-3620] fix errors
introduced by cherry-picking from master branch
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 3fb9fe8 [STORM-3620] fix errors introduced by cherry-picking from master branch
new 619b189 Merge pull request #3285 from Ethanlm/STORM-3620-fix-2.2.x
3fb9fe8 is described below
commit 3fb9fe8b67a08ae6fbe8470e67de8db6f5fcbaa5
Author: Ethan Li <et...@gmail.com>
AuthorDate: Tue Jun 9 22:28:01 2020 -0500
[STORM-3620] fix errors introduced by cherry-picking from master branch
---
.../org/apache/storm/executor/ExecutorTransferMultiThreadingTest.java | 2 +-
1 file changed, 1 insertion(+), 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..6e8a5d2 100644
--- a/storm-client/test/jvm/org/apache/storm/executor/ExecutorTransferMultiThreadingTest.java
+++ b/storm-client/test/jvm/org/apache/storm/executor/ExecutorTransferMultiThreadingTest.java
@@ -96,7 +96,7 @@ public class ExecutorTransferMultiThreadingTest {
//But there is already one worker transfer queue initialized by WorkerTransfer class (taskId=-1).
//However the taskId is only used for metrics and it is not important here. Making it -100 to avoid collision.
transferQueue = new JCQueue("worker-transfer-queue", 1024, 0, 1, new WaitStrategyPark(100),
- workerState.getTopologyId(), Constants.SYSTEM_COMPONENT_ID, Collections.singletonList(-100), workerState.getPort(),
+ workerState.getTopologyId(), Constants.SYSTEM_COMPONENT_ID, -100, workerState.getPort(),
workerState.getMetricRegistry());
//Replace the transferQueue inside WorkerTransfer (inside WorkerState) with the customized transferQueue to be used in this test