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

qiaojialin pushed a commit to branch rel/0.12
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rel/0.12 by this push:
     new 5d1b48aeb8 change sub thread error log to warning log (#6589)
5d1b48aeb8 is described below

commit 5d1b48aeb834c00e38b69b41697b770796ce6bda
Author: Jackie Tien <[email protected]>
AuthorDate: Wed Jul 6 09:32:30 2022 +0800

    change sub thread error log to warning log (#6589)
---
 .../iotdb/db/query/dataset/RawQueryDataSetWithoutValueFilter.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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 b03c106ce7..a3c055ddd4 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
@@ -130,7 +130,7 @@ public class RawQueryDataSetWithoutValueFilter extends 
QueryDataSet
           reader.setManagedByQueryManager(false);
         }
       } catch (InterruptedException e) {
-        LOGGER.error("Interrupted while putting into the blocking queue: ", e);
+        LOGGER.warn("Interrupted while putting into the blocking queue: ", e);
         Thread.currentThread().interrupt();
         reader.setHasRemaining(false);
       } catch (IOException e) {
@@ -145,11 +145,11 @@ public class RawQueryDataSetWithoutValueFilter extends 
QueryDataSet
 
     private void putExceptionBatchData(Throwable e, String logMessage) {
       try {
-        LOGGER.error(logMessage, e);
+        LOGGER.warn(logMessage, e);
         reader.setHasRemaining(false);
         blockingQueue.put(new ExceptionBatchData(e));
       } catch (InterruptedException ex) {
-        LOGGER.error("Interrupted while putting ExceptionBatchData into the 
blocking queue: ", ex);
+        LOGGER.warn("Interrupted while putting ExceptionBatchData into the 
blocking queue: ", ex);
         Thread.currentThread().interrupt();
       }
     }

Reply via email to