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();
}
}