[incubator-pulsar] branch master updated: Use SigKill to kill python process as opposed to sigterm which can be caught (#2514)

[sa...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 45d1a99  Use SigKill to kill python process as opposed to sigterm which can be caught (#2514)
45d1a99 is described below

commit 45d1a99c1e04e28381be07c708f34c53609660de
Author: Sanjeev Kulkarni <sa...@gmail.com>
AuthorDate: Wed Sep 5 10:22:27 2018 -0700

    Use SigKill to kill python process as opposed to sigterm which can be caught (#2514)
---
 pulsar-functions/instance/src/main/python/python_instance.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-functions/instance/src/main/python/python_instance.py b/pulsar-functions/instance/src/main/python/python_instance.py
index ce99020..b43b882 100644
--- a/pulsar-functions/instance/src/main/python/python_instance.py
+++ b/pulsar-functions/instance/src/main/python/python_instance.py
@@ -148,7 +148,7 @@ class PythonInstance(object):
   def process_spawner_health_check_timer(self):
     if time.time() - self.last_health_check_ts > 90:
       Log.critical("Haven't received health check from spawner in a while. Stopping instance...")
-      os.kill(os.getpid(), signal.SIGTERM)
+      os.kill(os.getpid(), signal.SIGKILL)
       sys.exit(1)
 
     Timer(30, self.process_spawner_health_check_timer).start()