commit 07af9709ad2ec6854c478b5561137852baf8ae11
author cjljohnson <cjljohnson@gmail.com> Mon Jan 06 22:44:36 2020 +0000
committer Meng Li (Ethan) <ethanopensource@gmail.com> Mon Jan 06 16:44:36 2020 -0600
tree 5412e5ccbd43e79c5f0ebaa75bc0d325de28b35e
parent f1313c1c606cb765c9b683f552013a93332ca206

STORM-3548 Remove iterator from Task.sendUnanchored (#3175)

storm-client/src/jvm/org/apache/storm/daemon/Task.java

diff --git a/storm-client/src/jvm/org/apache/storm/daemon/Task.java b/storm-client/src/jvm/org/apache/storm/daemon/Task.java
index 2f2d53b..59f2547 100644
--- a/storm-client/src/jvm/org/apache/storm/daemon/Task.java
+++ b/storm-client/src/jvm/org/apache/storm/daemon/Task.java
@@ -206,8 +206,8 @@
     public void sendUnanchored(String stream, List<Object> values, ExecutorTransfer transfer, Queue<AddressedTuple> pendingEmits) {
         Tuple tuple = getTuple(stream, values);
         List<Integer> tasks = getOutgoingTasks(stream, values);
-        for (Integer t : tasks) {
-            AddressedTuple addressedTuple = new AddressedTuple(t, tuple);
+        for (int i = 0; i < tasks.size(); i++) {
+            AddressedTuple addressedTuple = new AddressedTuple(tasks.get(i), tuple);
             transfer.tryTransfer(addressedTuple, pendingEmits);
         }
     }