no need to apply MVAnalyzerRule for Command

apache · Feb 12, 2019 · e09ead1 · e09ead1
1 parent 75d9eae
commit e09ead1
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/integration/spark2/src/main/commonTo2.2And2.3/org/apache/spark/sql/hive/CarbonAnalyzer.scala b/integration/spark2/src/main/commonTo2.2And2.3/org/apache/spark/sql/hive/CarbonAnalyzer.scala
@@ -19,7 +19,7 @@ package org.apache.spark.sql.hive
 import org.apache.spark.sql.SparkSession
 import org.apache.spark.sql.catalyst.analysis.Analyzer
 import org.apache.spark.sql.catalyst.catalog.SessionCatalog
-import org.apache.spark.sql.catalyst.plans.logical.LogicalPlan
+import org.apache.spark.sql.catalyst.plans.logical.{Command, LogicalPlan}
 import org.apache.spark.sql.catalyst.rules.Rule
 import org.apache.spark.sql.internal.SQLConf
 import org.apache.spark.util.CarbonReflectionUtils
@@ -42,10 +42,10 @@ class CarbonAnalyzer(catalog: SessionCatalog,
     var logicalPlan = analyzer.execute(plan)
     logicalPlan = CarbonPreAggregateDataLoadingRules(sparkSession).apply(logicalPlan)
     logicalPlan = CarbonPreAggregateQueryRules(sparkSession).apply(logicalPlan)
-    if (mvPlan != null) {
+    if (mvPlan != null && !logicalPlan.isInstanceOf[Command]) {
       mvPlan.apply(logicalPlan)
     } else {
       logicalPlan
     }
   }
-}
+}