itholic commented on code in PR #49014:
URL: https://github.com/apache/spark/pull/49014#discussion_r1881437503
##########
sql/core/src/test/scala/org/apache/spark/sql/SparkSessionJobTaggingAndCancellationSuite.scala:
##########
@@ -330,4 +330,109 @@ class SparkSessionJobTaggingAndCancellationSuite
threadPool.shutdownNow()
}
}
+
+ test("Interrupt jobs by tag") {
Review Comment:
Hi @xupefei could you check my last comment above when you have some time?
I wonder if we should fix the Scala side logic or should we just fix the
test? (btw this test scenario is working properly from Spark Connect Python
Client so I think anyway we should match the behavior)
also cc @HyukjinKwon fyi
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
