This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch rel/0.13
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/rel/0.13 by this push:
new 44f98cace7 print absolute file path when flush error occured (#7416)
44f98cace7 is described below
commit 44f98cace7c976a4bb9f0964f783f5eae2ae806f
Author: Haonan <[email protected]>
AuthorDate: Fri Sep 23 10:26:36 2022 +0800
print absolute file path when flush error occured (#7416)
---
.../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());
}