Updates comment per feedback

confluentinc · Jan 22, 2021 · fe21cfc · fe21cfc
1 parent 55d3da3
commit fe21cfc
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...rc/main/java/io/confluent/ksql/rest/server/resources/streaming/PullQueryStreamWriter.java b/...rc/main/java/io/confluent/ksql/rest/server/resources/streaming/PullQueryStreamWriter.java
@@ -349,6 +349,8 @@ public PullQueryRow pollNextRow() throws InterruptedException {
 
       if (row != null) {
         // The head becomes the next thing to process and the newly polled row becomes the head.
+        // The first time this is run, we'll always return null since we're keeping the row as the
+        // new head.
         final PullQueryRow toProcess = head;
         head = row;
         return toProcess;