Repository: ambari Updated Branches: refs/heads/trunk a7a8f1be2 -> 4482d2ccd
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/4482d2cc Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/4482d2cc Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/4482d2cc Branch: refs/heads/trunk Commit: 4482d2ccd30ffe587dd09d9106381c60ddbf52ee Parents: a7a8f1b Author: Alejandro Fernandez <[email protected]> Authored: Fri Oct 31 15:31:02 2014 -0700 Committer: Alejandro Fernandez <[email protected]> Committed: Fri Oct 31 15:34:49 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/4482d2cc/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 09e5413..0ebbee5 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 @@ -69,9 +69,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
