cloud-fan commented on code in PR #47374:
URL: https://github.com/apache/spark/pull/47374#discussion_r1689196166
##########
sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkExecuteStatementOperation.scala:
##########
@@ -249,10 +249,11 @@ private[hive] class SparkExecuteStatementOperation(
case e: Throwable =>
// When cancel() or close() is called very quickly after the query is
started,
// then they may both call cleanup() before Spark Jobs are started.
But before background
- // task interrupted, it may have start some spark job, so we need to
cancel again to
+ // task interrupted, it may have started some spark job, so we need to
cancel again to
// make sure job was cancelled when background thread was interrupted
if (statementId != null) {
- session.sparkContext.cancelJobGroup(statementId)
+ session.sparkContext.cancelJobGroup(statementId,
+ s"failed to execute statement ${redactedStatement}: " +
SparkUtils.exceptionString(e))
Review Comment:
`The corresponding Thriftserver query has failed.`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
