srielau commented on code in PR #53530: URL: https://github.com/apache/spark/pull/53530#discussion_r2733585289
########## sql/core/src/main/scala/org/apache/spark/sql/scripting/SqlScriptingExecutionNode.scala: ########## @@ -314,6 +314,12 @@ class CompoundBodyExec( /** Used to stop the iteration in cases when LEAVE statement is encountered. */ private var stopIteration = false + /** + * Flag to prevent advancing curr after an exception was thrown and handled by a CONTINUE handler. + * When true, the next call to next() should return curr without advancing. + */ + private[scripting] var returnCurrentWithoutAdvancing = false Review Comment: Replaced with "official fix" -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
