This is an automated email from the ASF dual-hosted git repository. jiangtian pushed a commit to branch fix_load_directory_full in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit add3f1899ac0d9d3c12d44faa8f607ca24071b21 Author: DESKTOP-L0L5GPJ\jt <[email protected]> AuthorDate: Sun Jul 14 17:42:57 2024 +0800 do not remove top-level load dir after load --- .../db/queryengine/execution/load/LoadTsFileManager.java | 16 ---------------- 1 file changed, 16 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/load/LoadTsFileManager.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/load/LoadTsFileManager.java index 0e0be8deae6..3c9548da27f 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/load/LoadTsFileManager.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/load/LoadTsFileManager.java @@ -296,22 +296,6 @@ public class LoadTsFileManager { if (Objects.nonNull(writerManager)) { writerManager.close(); } - - for (final Path loadDirPath : - Arrays.stream(LOAD_BASE_DIRS.get()) - .map(File::new) - .filter(File::exists) - .map(File::toPath) - .collect(Collectors.toList())) { - try { - Files.deleteIfExists(loadDirPath); - LOGGER.info("Load dir {} was deleted.", loadDirPath); - } catch (DirectoryNotEmptyException e) { - LOGGER.info("Load dir {} is not empty, skip deleting.", loadDirPath); - } catch (Exception e) { - LOGGER.info(MESSAGE_DELETE_FAIL, loadDirPath); - } - } } public static void updateWritePointCountMetrics(
