This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch QueryBlocking
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/QueryBlocking by this push:
     new 63f1483  format code
63f1483 is described below

commit 63f1483f2767cd31e73c419fa7ba6d1bfa12e526
Author: JackieTien97 <[email protected]>
AuthorDate: Tue Jan 4 16:16:06 2022 +0800

    format code
---
 .../iotdb/db/query/dataset/RawQueryDataSetWithoutValueFilter.java      | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/query/dataset/RawQueryDataSetWithoutValueFilter.java
 
b/server/src/main/java/org/apache/iotdb/db/query/dataset/RawQueryDataSetWithoutValueFilter.java
index 21d612e..b03c106 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/query/dataset/RawQueryDataSetWithoutValueFilter.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/query/dataset/RawQueryDataSetWithoutValueFilter.java
@@ -101,7 +101,8 @@ public class RawQueryDataSetWithoutValueFilter extends 
QueryDataSet
                 // the queue has enough space to hold SignalBatchData, just 
break the while loop
                 if (blockingQueue.remainingCapacity() > 0) {
                   break;
-                } else { // otherwise, exit without putting SignalBatchData, 
main thread will submit a new task again, then it will put SignalBatchData 
successfully
+                } else { // otherwise, exit without putting SignalBatchData, 
main thread will submit
+                  // a new task again, then it will put SignalBatchData 
successfully
                   reader.setManagedByQueryManager(false);
                   return;
                 }

Reply via email to