Github user marmbrus commented on a diff in the pull request:
https://github.com/apache/spark/pull/20598#discussion_r168011940
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MicroBatchExecution.scala
---
@@ -440,8 +444,6 @@ class MicroBatchExecution(
// Rewire the plan to use the new attributes that were returned by the
source.
val replacementMap = AttributeMap(replacements)
--- End diff --
Same
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
