Fix Expand.

apache · Aug 14, 2017 · 8f3b984 · 8f3b984
1 parent 1694c9b
commit 8f3b984
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/ExpandExec.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/ExpandExec.scala
@@ -89,6 +89,8 @@ case class ExpandExec(
     child.asInstanceOf[CodegenSupport].inputRDDs()
   }
 
+  override protected def isConsumeInSeparateFunc: Boolean = false
+
   protected override def doProduce(ctx: CodegenContext): String = {
     child.asInstanceOf[CodegenSupport].produce(ctx, this)
   }