Repository: storm Updated Branches: refs/heads/1.1.x-branch de731941d -> bb4e68c58
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/40a97ef5 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/40a97ef5 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/40a97ef5 Branch: refs/heads/1.1.x-branch Commit: 40a97ef52711441100b5e5779288ec1c16cf8786 Parents: de73194 Author: Jungtaek Lim <[email protected]> Authored: Thu Aug 24 20:11:41 2017 +0900 Committer: Jungtaek Lim <[email protected]> Committed: Sat Aug 26 21:16:17 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/40a97ef5/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)) ]
