From 39c09fe2b897f0d74d8b2a8ad058b100c974e019 Mon Sep 17 00:00:00 2001 From: Michael Armbrust Date: Sat, 3 May 2014 17:13:58 -0700 Subject: [PATCH] Fix off by one error. --- .../org/apache/spark/sql/catalyst/rules/RuleExecutor.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/rules/RuleExecutor.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/rules/RuleExecutor.scala index 009f4fcc5ff74..e32adb76fe146 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/rules/RuleExecutor.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/rules/RuleExecutor.scala @@ -71,7 +71,7 @@ abstract class RuleExecutor[TreeType <: TreeNode[_]] extends Logging { result } iteration += 1 - if (iteration >= batch.strategy.maxIterations) { + if (iteration > batch.strategy.maxIterations) { logger.info(s"Max iterations ($iteration) reached for batch ${batch.name}") continue = false }