clarify comment

apache · Jan 3, 2018 · 8f3629d · 8f3629d
1 parent 0059ff3
commit 8f3629d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MicroBatchExecution.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MicroBatchExecution.scala
@@ -478,7 +478,7 @@ class MicroBatchExecution(
         sink match {
           case s: Sink => s.addBatch(currentBatchId, nextBatch)
           case s: MicroBatchWriteSupport =>
-            // Execute the V2 writer node in the query plan.
+            // This doesn't accumulate any data - it just forces execution of the microbatch writer.
             nextBatch.collect()
         }
       }