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 2023/02/27 09:23:29 UTC
[iotdb] 02/03: avoid too much warn log
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch geely_car_0206
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit d859c7691a982dc53601ef4e3707657124cc4309
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Mon Feb 27 16:14:34 2023 +0800
avoid too much warn log
---
.../iotdb/db/mpp/execution/exchange/sink/ShuffleSinkHandle.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/sink/ShuffleSinkHandle.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/sink/ShuffleSinkHandle.java
index 9b18f4f771..90f601ecae 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/sink/ShuffleSinkHandle.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/sink/ShuffleSinkHandle.java
@@ -162,13 +162,17 @@ public class ShuffleSinkHandle implements ISinkHandle {
return;
}
LOGGER.debug("[StartAbortShuffleSinkHandle]");
+ boolean abortFailed = false;
for (ISink channel : downStreamChannelList) {
try {
channel.abort();
} catch (Exception e) {
- LOGGER.warn("Error occurred when try to abort channel.");
+ abortFailed = true;
}
}
+ if (abortFailed) {
+ LOGGER.warn("Error occurred when try to abort channel.");
+ }
aborted = true;
sinkListener.onAborted(this);
LOGGER.debug("[EndAbortShuffleSinkHandle]");