diff --git a/python/pyspark/core/context.py b/python/pyspark/core/context.py index 54e955318caa7..78cf7f1413129 100644 --- a/python/pyspark/core/context.py +++ b/python/pyspark/core/context.py @@ -405,8 +405,10 @@ def _do_init( # create a signal handler which would be invoked on receiving SIGINT def signal_handler(signal: Any, frame: Any) -> NoReturn: - self.cancelAllJobs() - raise KeyboardInterrupt() + try: + self.cancelAllJobs() + finally: + raise KeyboardInterrupt() # see http://stackoverflow.com/questions/23206787/ if isinstance(