Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/21662#discussion_r200532848
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/IncrementalExecution.scala
---
@@ -136,6 +137,11 @@ class IncrementalExecution(
j.left.output, j.right.output, j.leftKeys, j.rightKeys,
j.condition.full,
Some(offsetSeqMetadata.batchWatermarkMs))
)
+
+ case l: StreamingGlobalLimitExec =>
+ l.copy(
+ stateInfo = Some(nextStatefulOperationStateInfo),
--- End diff --
incorrect indent.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
