You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@heron.apache.org by hu...@apache.org on 2019/01/18 20:55:39 UTC
[incubator-heron] branch huijunw/fixexecutorassert updated:
add_method_doc
This is an automated email from the ASF dual-hosted git repository.
huijun pushed a commit to branch huijunw/fixexecutorassert
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git
The following commit(s) were added to refs/heads/huijunw/fixexecutorassert by this push:
new 4419ba8 add_method_doc
4419ba8 is described below
commit 4419ba85b59d5a44381b1eb74111e5e6ea45303c
Author: Huijun Wu <hu...@twitter.com>
AuthorDate: Fri Jan 18 12:55:11 2019 -0800
add_method_doc
---
heron/executor/src/python/heron_executor.py | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/heron/executor/src/python/heron_executor.py b/heron/executor/src/python/heron_executor.py
index 6c8779d..39a8f98 100755
--- a/heron/executor/src/python/heron_executor.py
+++ b/heron/executor/src/python/heron_executor.py
@@ -976,6 +976,11 @@ class HeronExecutor(object):
log_pid_for_process(name, p.pid)
def get_commands_to_run(self):
+ """
+ Prepare either TMaster or Streaming commands according to shard.
+ The Shell command is attached to all containers. The empty container plan and non-exist
+ container plan are bypassed.
+ """
# During shutdown the watch might get triggered with the empty packing plan
if len(self.packing_plan.container_plans) == 0:
return {}