This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch ab_13 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 6982fc387ad0064e1098eaf8e796162c26fabc19 Author: HTHou <[email protected]> AuthorDate: Fri Sep 23 10:12:04 2022 +0800 print absolute file path when flush error occured --- .../iotdb/db/engine/storagegroup/TsFileProcessor.java | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java index 0fb817e36b..1cb31057e5 100644 --- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java @@ -1039,7 +1039,7 @@ public class TsFileProcessor { logger.info( "{}: {} is closed during flush, abandon flush task", storageGroupName, - tsFileResource.getTsFile().getName()); + tsFileResource.getTsFile().getAbsolutePath()); synchronized (flushingMemTables) { flushingMemTables.notifyAll(); } @@ -1047,21 +1047,21 @@ public class TsFileProcessor { logger.error( "{}: {} meet error when flushing a memtable, change system mode to error", storageGroupName, - tsFileResource.getTsFile().getName(), + tsFileResource.getTsFile().getAbsolutePath(), e); IoTDBDescriptor.getInstance().getConfig().setSystemStatus(SystemStatus.ERROR); try { logger.error( "{}: {} IOTask meets error, truncate the corrupted data", storageGroupName, - tsFileResource.getTsFile().getName(), + tsFileResource.getTsFile().getAbsolutePath(), e); writer.reset(); } catch (IOException e1) { logger.error( "{}: {} Truncate corrupted data meets error", storageGroupName, - tsFileResource.getTsFile().getName(), + tsFileResource.getTsFile().getAbsolutePath(), e1); } // release resource @@ -1086,7 +1086,7 @@ public class TsFileProcessor { logger.error( "{}: {} Release resource meets error", storageGroupName, - tsFileResource.getTsFile().getName(), + tsFileResource.getTsFile().getAbsolutePath(), e1); } return; @@ -1118,7 +1118,7 @@ public class TsFileProcessor { } catch (IOException e) { logger.error( "Meet error when writing into ModificationFile file of {} ", - tsFileResource.getTsFile().getName(), + tsFileResource.getTsFile().getAbsolutePath(), e); } finally { flushQueryLock.writeLock().unlock(); @@ -1128,7 +1128,7 @@ public class TsFileProcessor { logger.debug( "{}: {} try get lock to release a memtable (signal={})", storageGroupName, - tsFileResource.getTsFile().getName(), + tsFileResource.getTsFile().getAbsolutePath(), memTableToFlush.isSignalMemTable()); }
