Also deal with sort case.

apache · Aug 13, 2017 · 502139a · 502139a
1 parent 6d600d5
commit 502139a
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/SortExec.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/SortExec.scala
@@ -177,6 +177,8 @@ case class SortExec(
      """.stripMargin.trim
   }
 
+  override protected def effectiveContinueStatement: String = "continue;"
+
   protected override val shouldStopRequired = false
 
   override def doConsume(ctx: CodegenContext, input: Seq[ExprCode], row: ExprCode): String = {