Fix off by one error.

marmbrus · marmbrus · commit 39c09fe2b897 · 2014-05-03T17:13:58.000-07:00
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
@@ -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
         }

Original file line number	Diff line number	Diff line change
`@@ -71,7 +71,7 @@ abstract class RuleExecutor[TreeType <: TreeNode[_]] extends Logging {`
`71`	`71`	`result`
`72`	`72`	`}`
`73`	`73`	`iteration += 1`
`74`		`- if (iteration >= batch.strategy.maxIterations) {`
	`74`	`+ if (iteration > batch.strategy.maxIterations) {`
`75`	`75`	`logger.info(s"Max iterations ($iteration) reached for batch ${batch.name}")`
`76`	`76`	`continue = false`
`77`	`77`	`}`