Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/19811#discussion_r157797890
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/WholeStageCodegenExec.scala
---
@@ -282,9 +282,10 @@ case class InputAdapter(child: SparkPlan) extends
UnaryExecNode with CodegenSupp
}
override def doProduce(ctx: CodegenContext): String = {
- val input = ctx.freshName("input")
// Right now, InputAdapter is only used when there is one input RDD.
- ctx.addMutableState("scala.collection.Iterator", input, s"$input =
inputs[0];")
+ // inline mutable state since an inputAdaptor in a task
--- End diff --
typo
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
