From c485df6b243e8bb7346c690a69e0f0366c4704b9 Mon Sep 17 00:00:00 2001 From: Kent Yao Date: Fri, 23 Oct 2020 00:52:07 +0800 Subject: [PATCH] sep spark proc buider suite --- .../engine/spark/SparkProcessBuilderSuite.scala | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/kyuubi-main/src/test/scala/org/apache/kyuubi/engine/spark/SparkProcessBuilderSuite.scala b/kyuubi-main/src/test/scala/org/apache/kyuubi/engine/spark/SparkProcessBuilderSuite.scala index 9679ec181..dfd2dd591 100644 --- a/kyuubi-main/src/test/scala/org/apache/kyuubi/engine/spark/SparkProcessBuilderSuite.scala +++ b/kyuubi-main/src/test/scala/org/apache/kyuubi/engine/spark/SparkProcessBuilderSuite.scala @@ -24,13 +24,13 @@ import org.apache.kyuubi.config.KyuubiConf import org.apache.kyuubi.config.KyuubiConf._ class SparkProcessBuilderSuite extends KyuubiFunSuite { + private val conf = KyuubiConf() + .set(EMBEDDED_ZK_PORT, 5555) + .set(EMBEDDED_ZK_TEMP_DIR, "spark_process_test") + .set("kyuubi.on", "off") + .toSparkPrefixedConf test("spark process builder") { - val conf = KyuubiConf() - .set(EMBEDDED_ZK_PORT, 5555) - .set(EMBEDDED_ZK_TEMP_DIR, "spark_process_test") - .set("kyuubi.on", "off") - .toSparkPrefixedConf val builder = new SparkProcessBuilder("kentyao", conf) val commands = builder.toString.split(' ') assert(commands(2) === "org.apache.kyuubi.engine.spark.SparkSQLEngine") @@ -42,7 +42,9 @@ class SparkProcessBuilderSuite extends KyuubiFunSuite { val process = builder.start assert(process.isAlive) process.destroyForcibly() + } + test("capture error from spark process builder") { val processBuilder = new SparkProcessBuilder("kentyao", conf ++ Map("spark.ui.port" -> "abc")) processBuilder.start Thread.sleep(5000)