You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@heron.apache.org by nl...@apache.org on 2019/04/10 18:29:22 UTC

[incubator-heron] branch master updated: Fix heron-shell command invocation (#3236)

This is an automated email from the ASF dual-hosted git repository.

nlu90 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git


The following commit(s) were added to refs/heads/master by this push:
     new facd7e7  Fix heron-shell command invocation (#3236)
facd7e7 is described below

commit facd7e7081c4849577c91255ce4d5b1c5d5a9614
Author: Xiaoyao Qian <qi...@illinois.edu>
AuthorDate: Wed Apr 10 11:29:16 2019 -0700

    Fix heron-shell command invocation (#3236)
---
 heron/executor/src/python/heron_executor.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/heron/executor/src/python/heron_executor.py b/heron/executor/src/python/heron_executor.py
index e727fdd..0c8f21c 100755
--- a/heron/executor/src/python/heron_executor.py
+++ b/heron/executor/src/python/heron_executor.py
@@ -1033,11 +1033,11 @@ class HeronExecutor(object):
       return {}
     if self._get_instance_plans(self.packing_plan, self.shard) is None and self.shard != 0:
       retval = {}
-      retval['heron-shell'] = [
+      retval['heron-shell'] = Command([
           '%s' % self.heron_shell_binary,
           '--port=%s' % self.shell_port,
           '--log_file_prefix=%s/heron-shell-%s.log' % (self.log_dir, self.shard),
-          '--secret=%s' % self.topology_id]
+          '--secret=%s' % self.topology_id], self.shell_env)
       return retval
 
     if self.shard == 0: