diff --git a/ujes/definedEngines/spark/engine/src/main/scala/com/webank/wedatasphere/linkis/engine/executors/SparkEngineExecutor.scala b/ujes/definedEngines/spark/engine/src/main/scala/com/webank/wedatasphere/linkis/engine/executors/SparkEngineExecutor.scala index 5772262783..634a672c00 100644 --- a/ujes/definedEngines/spark/engine/src/main/scala/com/webank/wedatasphere/linkis/engine/executors/SparkEngineExecutor.scala +++ b/ujes/definedEngines/spark/engine/src/main/scala/com/webank/wedatasphere/linkis/engine/executors/SparkEngineExecutor.scala @@ -39,7 +39,7 @@ import org.apache.commons.lang.StringUtils import org.apache.spark.SparkContext import org.apache.spark.sql.DataFrame import org.apache.spark.ui.jobs.JobProgressListener -import org.scalactic.Pass + import scala.collection.mutable.ArrayBuffer @@ -134,7 +134,7 @@ class SparkEngineExecutor(val sc: SparkContext, id: Long, outputPrintLimit: Int, } info(s"Start to structure sparksql resultset") response - }(Pass) + }{} override protected def executeCompletely(engineExecutorContext: EngineExecutorContext, code: String, completedLine: String): ExecuteResponse = { val newcode = completedLine + code