Shixiong Zhu created SPARK-4097: ----------------------------------- Summary: Race condition in org.apache.spark.ComplexFutureAction.cancel Key: SPARK-4097 URL: https://issues.apache.org/jira/browse/SPARK-4097 Project: Spark Issue Type: Bug Components: Spark Core Affects Versions: 1.1.0 Reporter: Shixiong Zhu Priority: Minor
There is a chance that `thread` is null when calling `thread.interrupt()`. {code:scala} override def cancel(): Unit = this.synchronized { _cancelled = true if (thread != null) { thread.interrupt() } } {code} Should put `thread = null` into a `synchronized` block to fix the race condition. {code:scala} try { p.success(func) } catch { case e: Exception => p.failure(e) } finally { thread = null } {code} -- 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