From 41f3a90175d6c6ab2e760d371d0ea75f1af4a7d7 Mon Sep 17 00:00:00 2001 From: Li Yuanjian Date: Thu, 14 Feb 2019 12:59:26 +0800 Subject: [PATCH] Fix UT (#7) --- .../spark/sql/execution/adaptive/InsertAdaptiveSparkPlan.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/InsertAdaptiveSparkPlan.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/InsertAdaptiveSparkPlan.scala index 4a1297b71feb8..adbf9e9deb238 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/InsertAdaptiveSparkPlan.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/InsertAdaptiveSparkPlan.scala @@ -34,5 +34,6 @@ case class InsertAdaptiveSparkPlan(session: SparkSession) extends Rule[SparkPlan case _: ExecutedCommandExec => plan case _ if session.sessionState.conf.adaptiveExecutionEnabled => AdaptiveSparkPlan(plan, session.cloneSession()) + case _ => plan } }