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 2015/04/22 23:38:58 UTC
[1/4] storm git commit: Skip ack init when there are no output tasks
Repository: storm
Updated Branches:
refs/heads/master 669d32828 -> 01969d8dd
Skip ack init when there are no output tasks
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/6602c4be
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/6602c4be
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/6602c4be
Branch: refs/heads/master
Commit: 6602c4becb7f22a14faab032872e51f70864530a
Parents: 2aaa718
Author: Derek Dagit <de...@yahoo-inc.com>
Authored: Thu Apr 2 08:55:03 2015 -0500
Committer: Derek Dagit <de...@yahoo-inc.com>
Committed: Thu Apr 2 08:55:03 2015 -0500
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/daemon/executor.clj | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/6602c4be/storm-core/src/clj/backtype/storm/daemon/executor.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/executor.clj b/storm-core/src/clj/backtype/storm/daemon/executor.clj
index 7f688ed..1c90921 100644
--- a/storm-core/src/clj/backtype/storm/daemon/executor.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/executor.clj
@@ -526,7 +526,8 @@
out-tuple
overflow-buffer)
))
- (if rooted?
+ (if (and rooted?
+ (seq out-ids)) ;; not empty
(do
(.put pending root-id [task-id
message-id
[3/4] storm git commit: Merge branch 'storm-746-ack-init-shortcut' of
https://github.com/d2r/storm into STORM-746
Posted by bo...@apache.org.
Merge branch 'storm-746-ack-init-shortcut' of https://github.com/d2r/storm into STORM-746
STORM-746: Skip ack init when there are no output tasks
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/4f4f2c48
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/4f4f2c48
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/4f4f2c48
Branch: refs/heads/master
Commit: 4f4f2c48d068b0f115ed635030eefe15baf897ef
Parents: 669d328 dd27ee4
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Wed Apr 22 16:28:19 2015 -0500
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Wed Apr 22 16:28:19 2015 -0500
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/daemon/executor.clj | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/4f4f2c48/storm-core/src/clj/backtype/storm/daemon/executor.clj
----------------------------------------------------------------------
[4/4] storm git commit: Added STORM-746 to Changelog
Posted by bo...@apache.org.
Added STORM-746 to Changelog
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/01969d8d
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/01969d8d
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/01969d8d
Branch: refs/heads/master
Commit: 01969d8dda09ad4cef248fcf302e97ca507e6fb6
Parents: 4f4f2c4
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Wed Apr 22 16:28:47 2015 -0500
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Wed Apr 22 16:28:47 2015 -0500
----------------------------------------------------------------------
CHANGELOG.md | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/01969d8d/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 4da34bf..6315f47 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
## 0.11.0
+ * STORM-746: Skip ack init when there are no output tasks
* STORM-483: provide dedicated directories for classpath extension
* STORM-764: Have option to compress thrift heartbeat
* STORM-787: test-ns should announce test failures with 'BUILD FAILURE'
[2/4] storm git commit: More efficient check for empty output task id
list
Posted by bo...@apache.org.
More efficient check for empty output task id list
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/dd27ee47
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/dd27ee47
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/dd27ee47
Branch: refs/heads/master
Commit: dd27ee47346fa417e6acb0cd68b9023d2d6dfe5a
Parents: 6602c4b
Author: Derek Dagit <de...@yahoo-inc.com>
Authored: Tue Apr 7 11:13:11 2015 -0500
Committer: Derek Dagit <de...@yahoo-inc.com>
Committed: Tue Apr 7 11:13:11 2015 -0500
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/daemon/executor.clj | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/dd27ee47/storm-core/src/clj/backtype/storm/daemon/executor.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/executor.clj b/storm-core/src/clj/backtype/storm/daemon/executor.clj
index 1c90921..c353512 100644
--- a/storm-core/src/clj/backtype/storm/daemon/executor.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/executor.clj
@@ -527,7 +527,7 @@
overflow-buffer)
))
(if (and rooted?
- (seq out-ids)) ;; not empty
+ (not (.isEmpty out-ids)))
(do
(.put pending root-id [task-id
message-id