Repository: ambari Updated Branches: refs/heads/trunk 7cb9a6ad5 -> 4deacdd7b
AMBARI-19972. Stop All services call failed to stop flume agent.(vbrodetskyi) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/4deacdd7 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/4deacdd7 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/4deacdd7 Branch: refs/heads/trunk Commit: 4deacdd7ba81ba4348d1929c09a66858dbd5ba6c Parents: 7cb9a6a Author: Vitaly Brodetskyi <[email protected]> Authored: Tue Feb 14 00:57:40 2017 +0200 Committer: Vitaly Brodetskyi <[email protected]> Committed: Tue Feb 14 00:57:40 2017 +0200 ---------------------------------------------------------------------- .../common-services/FLUME/1.4.0.2.0/package/scripts/flume.py | 4 +++- ambari-server/src/test/python/stacks/2.0.6/FLUME/test_flume.py | 4 ++-- 2 files changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/4deacdd7/ambari-server/src/main/resources/common-services/FLUME/1.4.0.2.0/package/scripts/flume.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/common-services/FLUME/1.4.0.2.0/package/scripts/flume.py b/ambari-server/src/main/resources/common-services/FLUME/1.4.0.2.0/package/scripts/flume.py index aeb7074..e1d1874 100644 --- a/ambari-server/src/main/resources/common-services/FLUME/1.4.0.2.0/package/scripts/flume.py +++ b/ambari-server/src/main/resources/common-services/FLUME/1.4.0.2.0/package/scripts/flume.py @@ -228,8 +228,10 @@ def flume(action = None): if is_flume_process_live(pid_file): pid = shell.checked_call(("cat", pid_file), sudo=True)[1].strip() Execute(("kill", "-15", pid), sudo=True) # kill command has to be a tuple + if not await_flume_process_termination(pid_file, try_count=30): + Execute(("kill", "-9", pid), sudo=True) - if not await_flume_process_termination(pid_file): + if not await_flume_process_termination(pid_file, try_count=10): show_logs(params.flume_log_dir, None) raise Fail("Can't stop flume agent: {0}".format(agent)) http://git-wip-us.apache.org/repos/asf/ambari/blob/4deacdd7/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 4cf43c1..02810e2 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 @@ -122,7 +122,7 @@ class TestFlumeHandler(RMFTestCase): target = RMFTestCase.TARGET_COMMON_SERVICES) self.assertTrue(glob_mock.called) - await_flume_process_termination_mock.assert_called_with('/var/run/flume/a1.pid') + await_flume_process_termination_mock.assert_called_with('/var/run/flume/a1.pid', try_count=10) self.assertTrue(set_desired_mock.called) self.assertTrue(set_desired_mock.call_args[0][0] == 'INSTALLED') @@ -421,7 +421,7 @@ class TestFlumeHandler(RMFTestCase): target = RMFTestCase.TARGET_COMMON_SERVICES) self.assertTrue(glob_mock.called) - await_flume_process_termination_mock.assert_called_with('/var/run/flume/b1.pid') + await_flume_process_termination_mock.assert_called_with('/var/run/flume/b1.pid', try_count=10) self.assertResourceCalled('File', '/var/run/flume/b1.pid', action = ['delete'])
