From cf76ca57920c92c35f82caf2752894536f0617e2 Mon Sep 17 00:00:00 2001 From: Liang-Chi Hsieh Date: Fri, 8 Sep 2017 07:16:11 +0000 Subject: [PATCH] Fix the condition. --- .../org/apache/spark/sql/catalyst/optimizer/Optimizer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala index 2426a8b4a9062..a602894efbcae 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala @@ -41,7 +41,7 @@ abstract class Optimizer(sessionCatalog: SessionCatalog) // Check for structural integrity of the plan in test mode. Currently we only check if a plan is // still resolved after the execution of each rule. override protected def isPlanIntegral(plan: LogicalPlan): Boolean = { - Utils.isTesting && plan.resolved + !Utils.isTesting || plan.resolved } protected def fixedPoint = FixedPoint(SQLConf.get.optimizerMaxIterations)