Skip to content

Commit

Permalink
delete useless code in SparkEngineExecutor
Browse files Browse the repository at this point in the history
  • Loading branch information
yangzhiyue committed Aug 6, 2019
1 parent 70a51b8 commit 66cd6dc
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand Down Expand Up @@ -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
Expand Down

0 comments on commit 66cd6dc

Please sign in to comment.