Repository: ambari Updated Branches: refs/heads/branch-1.7.0 21d965ef1 -> 95a43d7b3
AMBARI-8059. Flume Start is failing with pid returned 1 (alejandro) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/95a43d7b Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/95a43d7b Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/95a43d7b Branch: refs/heads/branch-1.7.0 Commit: 95a43d7b38edabe7563d7d9eb4104af9170a0df5 Parents: 21d965e Author: Alejandro Fernandez <afernan...@hortonworks.com> Authored: Fri Oct 31 15:36:17 2014 -0700 Committer: Alejandro Fernandez <afernan...@hortonworks.com> Committed: Fri Oct 31 15:36:17 2014 -0700 ---------------------------------------------------------------------- .../stacks/HDP/2.0.6/services/FLUME/package/scripts/flume.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/95a43d7b/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/FLUME/package/scripts/flume.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/FLUME/package/scripts/flume.py b/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/FLUME/package/scripts/flume.py index fa03c36..f977d4c 100644 --- a/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/FLUME/package/scripts/flume.py +++ b/ambari-server/src/main/resources/stacks/HDP/2.0.6/services/FLUME/package/scripts/flume.py @@ -67,9 +67,10 @@ def flume(action = None): # desired state for service should be STARTED if len(params.flume_command_targets) == 0: _set_desired_state('STARTED') - + + # It is important to run this command as a background process. flume_base = format('su -s /bin/bash {flume_user} -c "export JAVA_HOME={java_home}; ' - '{flume_bin} agent --name {{0}} --conf {{1}} --conf-file {{2}} {{3}}"') + '{flume_bin} agent --name {{0}} --conf {{1}} --conf-file {{2}} {{3}}" &') for agent in cmd_target_names(): flume_agent_conf_dir = params.flume_conf_dir + os.sep + agent
