You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/07/05 02:28:38 UTC

[iotdb] 01/01: delete data.zip

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

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

commit 079580ad9514f3ff787f4a528ad8622806b11082
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Tue Jul 5 10:28:22 2022 +0800

    delete data.zip
---
 .../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();
       }
     }