You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2016/02/16 16:12:49 UTC
[2/5] storm git commit: STORM-1272: Fix indentation
STORM-1272: Fix indentation
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/55b26dd6
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/55b26dd6
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/55b26dd6
Branch: refs/heads/master
Commit: 55b26dd639340ef928951eedc1bc783bf26b5b1e
Parents: c7e6689
Author: Abhishek Agarwal <ab...@inmobi.com>
Authored: Thu Feb 11 20:32:56 2016 +0530
Committer: Abhishek Agarwal <ab...@inmobi.com>
Committed: Thu Feb 11 20:32:56 2016 +0530
----------------------------------------------------------------------
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/55b26dd6/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 08bb2e6..619a885 100644
--- a/storm-core/src/clj/org/apache/storm/daemon/executor.clj
+++ b/storm-core/src/clj/org/apache/storm/daemon/executor.clj
@@ -220,7 +220,7 @@
(let [val (AddressedTuple. task tuple)]
(when (= true (storm-conf TOPOLOGY-DEBUG))
(log-message "TRANSFERING tuple " val))
- (.publish ^DisruptorQueue batch-transfer->worker val) )))
+ (.publish ^DisruptorQueue batch-transfer->worker val))))
(defn mk-executor-data [worker executor-id]
(let [worker-context (worker-context worker)