Repository: ambari Updated Branches: refs/heads/branch-1.7.0 eedf1e0e1 -> f1af2c5ea
AMBARI-8063 Flume: /etc/flume/conf/flume-env.sh not being used when multiple agents on host (dsen) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/f1af2c5e Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/f1af2c5e Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/f1af2c5e Branch: refs/heads/branch-1.7.0 Commit: f1af2c5eabef3bde63603315545e4039e05501c0 Parents: eedf1e0 Author: Dmytro Sen <[email protected]> Authored: Fri Oct 31 14:01:17 2014 +0200 Committer: Dmytro Sen <[email protected]> Committed: Fri Oct 31 14:01:17 2014 +0200 ---------------------------------------------------------------------- .../services/FLUME/package/scripts/flume.py | 11 +++++---- .../python/stacks/2.0.6/FLUME/test_flume.py | 25 ++++++++++++-------- 2 files changed, 21 insertions(+), 15 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/f1af2c5e/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 ab3d2c4..fa03c36 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 @@ -33,11 +33,6 @@ def flume(action = None): Directory(params.flume_conf_dir, recursive=True) Directory(params.flume_log_dir, owner=params.flume_user) - File(format("{flume_conf_dir}/flume-env.sh"), - owner=params.flume_user, - content=InlineTemplate(params.flume_env_sh_template) - ) - flume_agents = {} if params.flume_conf_content is not None: flume_agents = build_flume_topology(params.flume_conf_content) @@ -47,6 +42,7 @@ def flume(action = None): flume_agent_conf_file = os.path.join(flume_agent_conf_dir, 'flume.conf') flume_agent_meta_file = os.path.join(flume_agent_conf_dir, 'ambari-meta.json') flume_agent_log4j_file = os.path.join(flume_agent_conf_dir, 'log4j.properties') + flume_agent_env_file = os.path.join(flume_agent_conf_dir, 'flume-env.sh') Directory(flume_agent_conf_dir) @@ -62,6 +58,11 @@ def flume(action = None): content = json.dumps(ambari_meta(agent, flume_agents[agent])), mode = 0644) + File(flume_agent_env_file, + owner=params.flume_user, + content=InlineTemplate(params.flume_env_sh_template) + ) + elif action == 'start': # desired state for service should be STARTED if len(params.flume_command_targets) == 0: http://git-wip-us.apache.org/repos/asf/ambari/blob/f1af2c5e/ambari-server/src/test/python/stacks/2.0.6/FLUME/test_flume.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/test/python/stacks/2.0.6/FLUME/test_flume.py b/ambari-server/src/test/python/stacks/2.0.6/FLUME/test_flume.py index 86d1fd0..57234a3 100644 --- a/ambari-server/src/test/python/stacks/2.0.6/FLUME/test_flume.py +++ b/ambari-server/src/test/python/stacks/2.0.6/FLUME/test_flume.py @@ -160,11 +160,6 @@ class TestFlumeHandler(RMFTestCase): self.assertResourceCalled('Directory', '/var/log/flume', owner = 'flume') - self.assertResourceCalled('File', "/etc/flume/conf/flume-env.sh", - owner="flume", - content=InlineTemplate(self.getConfig()['configurations']['flume-env']['content']) - ) - self.assertResourceCalled('Directory', '/etc/flume/conf/a1') self.assertResourceCalled('PropertiesFile', '/etc/flume/conf/a1/flume.conf', @@ -182,17 +177,17 @@ class TestFlumeHandler(RMFTestCase): content='{"channels_count": 1, "sinks_count": 1, "sources_count": 1}', mode = 0644) + self.assertResourceCalled('File', "/etc/flume/conf/a1/flume-env.sh", + owner="flume", + content=InlineTemplate(self.getConfig()['configurations']['flume-env']['content']) + ) + def assert_configure_many(self): self.assertResourceCalled('Directory', '/etc/flume/conf', recursive=True) self.assertResourceCalled('Directory', '/var/log/flume', owner = 'flume') - self.assertResourceCalled('File', "/etc/flume/conf/flume-env.sh", - owner="flume", - content=InlineTemplate(self.getConfig()['configurations']['flume-env']['content']) - ) - top = build_flume(self.getConfig()['configurations']['flume-conf']['content']) # a1 @@ -209,6 +204,11 @@ class TestFlumeHandler(RMFTestCase): content='{"channels_count": 1, "sinks_count": 1, "sources_count": 1}', mode = 0644) + self.assertResourceCalled('File', "/etc/flume/conf/a1/flume-env.sh", + owner="flume", + content=InlineTemplate(self.getConfig()['configurations']['flume-env']['content']) + ) + # b1 self.assertResourceCalled('Directory', '/etc/flume/conf/b1') self.assertResourceCalled('PropertiesFile', '/etc/flume/conf/b1/flume.conf', @@ -222,6 +222,11 @@ class TestFlumeHandler(RMFTestCase): '/etc/flume/conf/b1/ambari-meta.json', content='{"channels_count": 1, "sinks_count": 1, "sources_count": 1}', mode = 0644) + self.assertResourceCalled('File', "/etc/flume/conf/b1/flume-env.sh", + owner="flume", + content=InlineTemplate(self.getConfig()['configurations']['flume-env']['content']) + ) + @patch("os.path.isfile") def test_start_single(self, os_path_isfile_mock):
