Repository: storm Updated Branches: refs/heads/1.x-branch 38dc90a69 -> e1c24b9b2
STORM-2231 Fix multi-threads issue on executor send queue * we have use cases which launches threads and emit/ack concurrently * launched threads will create ThreadLocalBatcher for each * hence 'synchronized' in add() wouldn't help unlike background flushes Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/501ef148 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/501ef148 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/501ef148 Branch: refs/heads/1.x-branch Commit: 501ef1489813753b9bbec72c0b43b6b696277c4a Parents: 38dc90a Author: Jungtaek Lim <[email protected]> Authored: Thu Aug 24 20:11:41 2017 +0900 Committer: Jungtaek Lim <[email protected]> Committed: Sat Aug 26 21:07:30 2017 +0900 ---------------------------------------------------------------------- storm-core/src/clj/org/apache/storm/daemon/executor.clj | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/501ef148/storm-core/src/clj/org/apache/storm/daemon/executor.clj ---------------------------------------------------------------------- diff --git a/storm-core/src/clj/org/apache/storm/daemon/executor.clj b/storm-core/src/clj/org/apache/storm/daemon/executor.clj index 9645b37..52063fc 100644 --- a/storm-core/src/clj/org/apache/storm/daemon/executor.clj +++ b/storm-core/src/clj/org/apache/storm/daemon/executor.clj @@ -231,7 +231,7 @@ (str "executor" executor-id "-send-queue") (storm-conf TOPOLOGY-EXECUTOR-SEND-BUFFER-SIZE) (storm-conf TOPOLOGY-DISRUPTOR-WAIT-TIMEOUT-MILLIS) - :producer-type :single-threaded + :producer-type :multi-threaded :batch-size (storm-conf TOPOLOGY-DISRUPTOR-BATCH-SIZE) :batch-timeout (storm-conf TOPOLOGY-DISRUPTOR-BATCH-TIMEOUT-MILLIS)) ]
