[
https://issues.apache.org/jira/browse/SPARK-49448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LIU closed SPARK-49448.
-----------------------
> Spark Connect ExecuteThreadRunner promise will always complete with success.
> ----------------------------------------------------------------------------
>
> Key: SPARK-49448
> URL: https://issues.apache.org/jira/browse/SPARK-49448
> Project: Spark
> Issue Type: Improvement
> Components: Connect
> Affects Versions: 4.0.0
> Reporter: LIU
> Priority: Minor
>
> {code:java}
> private class ExecutionThread(onCompletionPromise: Promise[Unit])
> extends
> Thread(s"SparkConnectExecuteThread_opId=${executeHolder.operationId}") {
> override def run(): Unit = {
> try {
> execute()
> onCompletionPromise.success(())
> } catch {
> case NonFatal(e) =>
> onCompletionPromise.failure(e)
> }
> }
> }{code}
>
> execute method end with ErrorUtils.handleError() function call. if any
> excetion throw. it will not catch by promise. is it better to catch real
> exceptions with promises instead of？ if wants. i will submit this change.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
