[ https://issues.apache.org/jira/browse/SPARK-3993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14175536#comment-14175536 ]
Apache Spark commented on SPARK-3993: ------------------------------------- User 'davies' has created a pull request for this issue: https://github.com/apache/spark/pull/2838 > python worker may hang after reused from take() > ----------------------------------------------- > > Key: SPARK-3993 > URL: https://issues.apache.org/jira/browse/SPARK-3993 > Project: Spark > Issue Type: Bug > Components: PySpark > Reporter: Davies Liu > Assignee: Davies Liu > Priority: Blocker > > After take(), maybe there are some garbage left in the socket, then next task > assigned to this worker will hang because of corrupted data. > We should make sure the socket is clean before reuse it. -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org