@Andrew_Or-2 I am using Scala futures.
--
View this message in context:
http://apache-spark-developers-list.1001551.n3.nabble.com/Concurrency-issue-in-SQLExecution-withNewExecutionId-tp14035p14068.html
Sent from the Apache Spark Developers List mailing list archive at Nabble.com.
-
@Olivier, did you use scala's parallel collections by any chance? If not,
what form of concurrency were you using?
2015-09-10 13:01 GMT-07:00 Andrew Or :
> Thanks for reporting this, I have filed
> https://issues.apache.org/jira/browse/SPARK-10548.
>
> 2015-09-10 9:09 GMT-07:00 Olivier Toupin :
>
Thanks for reporting this, I have filed
https://issues.apache.org/jira/browse/SPARK-10548.
2015-09-10 9:09 GMT-07:00 Olivier Toupin :
> Look at this code:
>
>
> https://github.com/apache/spark/blob/branch-1.5/sql/core/src/main/scala/org/apache/spark/sql/execution/SQLExecution.scala#L42
>
> and
>
Look at this code:
https://github.com/apache/spark/blob/branch-1.5/sql/core/src/main/scala/org/apache/spark/sql/execution/SQLExecution.scala#L42
and
https://github.com/apache/spark/blob/branch-1.5/sql/core/src/main/scala/org/apache/spark/sql/execution/SQLExecution.scala#L87
This exception is t