From 8f3629dea5a70e55a3c4c4e8a82604d2b1225c00 Mon Sep 17 00:00:00 2001
From: Jose Torres <jose@databricks.com>
Date: Wed, 3 Jan 2018 15:34:44 -0800
Subject: [PATCH] clarify comment

---
 .../spark/sql/execution/streaming/MicroBatchExecution.scala     | 2 +-
 1 file changed, 1 insertion(+), 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
index b6e6eefc5ea9e..ba2278822dab7 100644
--- 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()
         }
       }