Li Jin created SPARK-22655:
------------------------------

             Summary: Fail task instead of complete task silently in 
PythonRunner during shutdown
                 Key: SPARK-22655
                 URL: https://issues.apache.org/jira/browse/SPARK-22655
             Project: Spark
          Issue Type: Bug
          Components: PySpark
    Affects Versions: 2.2.0, 2.1.0, 2.0.2
            Reporter: Li Jin


We have observed in our production environment that during Spark shutdown, if 
there are some active tasks, sometimes they will complete with incorrect 
results. We've tracked down the issue to a PythonRunner where it is returning 
partial result instead of throwing exception during Spark shutdown. 

I think the better way to handle this is to have these tasks fail instead of 
complete with partial results (complete with partial is always bad IMHO)



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org

Reply via email to