You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@zeppelin.apache.org by "Jhon Cardenas (JIRA)" <ji...@apache.org> on 2018/06/14 19:05:00 UTC
[jira] [Created] (ZEPPELIN-3542) Stop a pyspark paragraph cancels
all the pyspark jobs of other users
Jhon Cardenas created ZEPPELIN-3542:
---------------------------------------
Summary: Stop a pyspark paragraph cancels all the pyspark jobs of other users
Key: ZEPPELIN-3542
URL: https://issues.apache.org/jira/browse/ZEPPELIN-3542
Project: Zeppelin
Issue Type: Bug
Components: pySpark
Affects Versions: 0.8.0
Environment: This happen when the spark context is shared between users (scoped).
Reporter: Jhon Cardenas
Stop a pyspark paragraph cancels all the pyspark jobs of other users.
Cancel button in pyspark paragraph cancels Spark jobs for all users.
This happen when the spark context is shared between users (scoped).
It seems to be related with [the solution|https://github.com/apache/zeppelin/commit/9f22db91c279b7daf6a13b2d805a874074b070fd] for the task [ZEPPELIN-2075|https://issues.apache.org/jira/browse/ZEPPELIN-2075].
This solution is causing that when one particular user cancels his py-spark job, the py-spark jobs from all the users are being canceled !!.
When a py-spark job is cancelled, the method PySparkInterpreter interrupt() is invoked, and then the SIGINT event is called, causing that all the jobs in the same spark context be cancelled:
context.py:
# create a signal handler which would be invoked on receiving SIGINT
def signal_handler(signal, frame):
self.cancelAllJobs()
raise KeyboardInterrupt()
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)