From 36832e2184fab25773849d3734a3c326cfbd41d2 Mon Sep 17 00:00:00 2001 From: Weihao Li <18110526956@163.com> Date: Sat, 5 Sep 2026 17:57:41 +0800 Subject: [PATCH] remove some stack print Signed-off-by: Weihao Li <18110526956@163.com> --- .../execution/exchange/MPPDataExchangeManager.java | 6 +++--- .../queryengine/plan/execution/QueryExecution.java | 3 +-- .../metadata/spill/DeviceEntryDiskSpiller.java | 3 +-- .../metadata/spill/DeviceEntryFileSpillerReader.java | 3 +-- .../metadata/spill/DeviceEntrySpillManager.java | 12 ++++-------- .../spill/LocalSegmentDeviceEntrySource.java | 3 ++- 6 files changed, 12 insertions(+), 18 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/exchange/MPPDataExchangeManager.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/exchange/MPPDataExchangeManager.java index f79c4da5d8c9..ceba3880122a 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/exchange/MPPDataExchangeManager.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/exchange/MPPDataExchangeManager.java @@ -65,6 +65,7 @@ import java.io.IOException; import java.nio.ByteBuffer; +import java.nio.file.AccessDeniedException; import java.nio.file.NoSuchFileException; import java.util.ArrayList; import java.util.List; @@ -115,7 +116,7 @@ public TFetchDeviceEntrySegmentResp fetchDeviceEntrySegment( return new TFetchDeviceEntrySegmentResp( new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode())) .setPayload(payload); - } catch (NoSuchFileException e) { + } catch (NoSuchFileException | AccessDeniedException e) { LOGGER.warn( String.format( DataNodeQueryMessages @@ -147,8 +148,7 @@ public TSStatus finishDeviceEntrySegment(String queryId, String planNodeId) { DataNodeQueryMessages .LOG_FAILED_TO_CLEAN_DEVICEENTRY_DATA_SET_ASYNCHRONOUSLY_QUERYID_ARG_PLANNODEID_ARG_9106C4C5, queryId, - planNodeId), - e); + planNodeId)); } }); return new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode()); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecution.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecution.java index a1abfcf1d440..40f5231a81fb 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecution.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecution.java @@ -446,8 +446,7 @@ private void releaseResource(Throwable t) { String.format( DataNodeQueryMessages .LOG_FAILED_TO_CLEAN_DEVICEENTRY_SPILL_DIRECTORY_FOR_QUERY_ARG_53D9C1FC, - context.getQueryId().getId()), - e); + context.getQueryId().getId())); } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryDiskSpiller.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryDiskSpiller.java index 8c52a25f3536..97e13661aa85 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryDiskSpiller.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryDiskSpiller.java @@ -142,8 +142,7 @@ public void close() throws IOException { String.format( DataNodeQueryMessages .LOG_FAILED_TO_CLEAN_DEVICEENTRY_SPILL_DIRECTORY_FOR_QUERY_ARG_53D9C1FC, - temporaryFile), - e); + temporaryFile)); } } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryFileSpillerReader.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryFileSpillerReader.java index 6bfedc83d09c..0843e58af93e 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryFileSpillerReader.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryFileSpillerReader.java @@ -126,8 +126,7 @@ private void closeCurrentSegment(boolean fullyConsumed) throws IOException { String.format( DataNodeQueryMessages .LOG_FAILED_TO_CLEAN_DEVICEENTRY_SPILL_DIRECTORY_FOR_QUERY_ARG_53D9C1FC, - currentSegment), - e); + currentSegment)); } } currentSegment = null; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntrySpillManager.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntrySpillManager.java index 35891e384d04..ebd4218672ab 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntrySpillManager.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntrySpillManager.java @@ -106,8 +106,7 @@ public void deleteSegment(String queryId, String dataSetId, int segmentId) throw String.format( DataNodeQueryMessages .LOG_FAILED_TO_CLEAN_DEVICEENTRY_SPILL_DIRECTORY_FOR_QUERY_ARG_53D9C1FC, - file), - e); + file)); } } @@ -180,8 +179,7 @@ public FileVisitResult visitFile(Path file, BasicFileAttributes attributes) String.format( DataNodeQueryMessages .LOG_FAILED_TO_CLEAN_DEVICEENTRY_SPILL_DIRECTORY_FOR_QUERY_ARG_53D9C1FC, - file), - e); + file)); } return FileVisitResult.CONTINUE; } @@ -198,8 +196,7 @@ public FileVisitResult visitFileFailed(Path file, IOException exception) String.format( DataNodeQueryMessages .LOG_FAILED_TO_CLEAN_DEVICEENTRY_SPILL_DIRECTORY_FOR_QUERY_ARG_53D9C1FC, - file), - exception); + file)); } return FileVisitResult.CONTINUE; } @@ -223,8 +220,7 @@ public FileVisitResult postVisitDirectory(Path dir, IOException exception) String.format( DataNodeQueryMessages .LOG_FAILED_TO_CLEAN_DEVICEENTRY_SPILL_DIRECTORY_FOR_QUERY_ARG_53D9C1FC, - dir), - e); + dir)); } return FileVisitResult.CONTINUE; } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/LocalSegmentDeviceEntrySource.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/LocalSegmentDeviceEntrySource.java index b60d6be6ba36..289c86bec2f0 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/LocalSegmentDeviceEntrySource.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/LocalSegmentDeviceEntrySource.java @@ -27,6 +27,7 @@ import org.slf4j.LoggerFactory; import java.io.IOException; +import java.nio.file.AccessDeniedException; import java.nio.file.NoSuchFileException; import java.util.List; @@ -57,7 +58,7 @@ public List nextBatch() throws IOException { spillManager.readSegment( handle.getQueryId(), handle.getPlanNodeId().getId(), segmentId)); releaseSegment(segmentId); - } catch (NoSuchFileException e) { + } catch (NoSuchFileException | AccessDeniedException e) { LOGGER.warn( String.format( DataNodeQueryMessages