Github user gatorsmile commented on a diff in the pull request: https://github.com/apache/spark/pull/18956#discussion_r137611075 --- Diff: sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/rules/RuleExecutor.scala --- @@ -93,6 +101,13 @@ abstract class RuleExecutor[TreeType <: TreeNode[_]] extends Logging { """.stripMargin) } + // Run the structural integrity checker against the plan after each rule. + if (!planChecker(result)) { + val message = s"After applying rule ${rule.ruleName} in batch ${batch.name}, " + + "the structural integrity of the plan is broken." + throw new TreeNodeException(result, message, null) --- End diff -- nvm. The message also has rule and batch names.
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org