Skip to content

Commit a6d5660

Browse files
committed
adapt to SPARK-54259
1 parent b877c32 commit a6d5660

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

kyuubi-server/src/test/scala/org/apache/kyuubi/server/rest/client/BatchCliSuite.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -259,7 +259,7 @@ class BatchCliSuite extends RestClientTestHelper with TestPrematureExit with Bat
259259
"--forward")
260260
result = testPrematureExitForControlCli(logArgs, "")
261261
assert(result.contains(s"Submitted application: $sparkBatchTestAppName"))
262-
assert(result.contains("Shutdown hook called"))
262+
assert(result.contains("Successfully stopped SparkContext"))
263263
}
264264

265265
test("submit batch test") {
@@ -272,7 +272,7 @@ class BatchCliSuite extends RestClientTestHelper with TestPrematureExit with Bat
272272
ldapUserPasswd)
273273
val result = testPrematureExitForControlCli(submitArgs, "")
274274
assert(result.contains(s"Submitted application: $sparkBatchTestAppName"))
275-
assert(result.contains("Shutdown hook called"))
275+
assert(result.contains("Successfully stopped SparkContext"))
276276
}
277277

278278
test("submit batch test with waitCompletion=false") {
@@ -289,7 +289,7 @@ class BatchCliSuite extends RestClientTestHelper with TestPrematureExit with Bat
289289
s"${CtlConf.CTL_BATCH_LOG_QUERY_INTERVAL.key}=100")
290290
val result = testPrematureExitForControlCli(submitArgs, "")
291291
assert(result.contains("bin/spark-submit"))
292-
assert(!result.contains("Shutdown hook called"))
292+
assert(!result.contains("Successfully stopped SparkContext"))
293293
}
294294

295295
test("list batch test") {

0 commit comments

Comments
 (0)