Fix lint

confluentinc · Jan 27, 2021 · 30e2976 · 30e2976
1 parent f9168bd
commit 30e2976
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/ksqldb-engine/src/main/java/io/confluent/ksql/query/PullQueryQueue.java b/ksqldb-engine/src/main/java/io/confluent/ksql/query/PullQueryQueue.java
@@ -203,8 +203,9 @@ public boolean acceptRow(final PullQueryRow row) {
 
   /**
    * If you don't want to rely on poll timeouts, a sentinel can be directly used, rather than
-   * interrupting the sleeping thread.
-   * @param row
+   * interrupting the sleeping thread. The main difference between this and acceptRow is that
+   * this allows the addition of the sentinel even if the queue is closed.
+   * @param row The row to use as the sentinel
    */
   public void putSentinelRow(final PullQueryRow row) {
     try {

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
@@ -90,7 +90,6 @@ public void write(final OutputStream output) {
     try {
       final WriterState writerState = new WriterState(clock);
       final QueueWrapper queueWrapper = new QueueWrapper(pullQueryQueue, disconnectCheckInterval);
-      long startMs = System.currentTimeMillis();
 
       // First write the header with the schema
       final StreamedRow header
@@ -323,7 +322,7 @@ public String getStringToFlush() {
    * if there's something next.
    */
   static final class QueueWrapper {
-    public final static PullQueryRow END_ROW = new PullQueryRow(null, null, null);
+    public static final PullQueryRow END_ROW = new PullQueryRow(null, null, null);
     private final PullQueryQueue pullQueryQueue;
     private final long disconnectCheckInterval;
     // We always keep a reference to the head of the queue so that we know if there's another