Add a comment to describe calling read() again.

apache · Sep 27, 2017 · 416bd10 · 416bd10
1 parent aa3fa70
commit 416bd10
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/python/ArrowPythonRunner.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/python/ArrowPythonRunner.scala
@@ -157,6 +157,7 @@ class ArrowPythonRunner(
               batch.setNumRows(root.getRowCount)
               batch
             } else {
+              // Reach end of stream. Call `read()` again to read control data.
               read()
             }
           } else {