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 {}