This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch tsfile-batch-ordering
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/tsfile-batch-ordering by this
push:
new d183447c288 Update PipeTabletEventTsFileBatch.java
d183447c288 is described below
commit d183447c2887117f352ac59f678fd2520425d19d
Author: Steve Yurong Su <[email protected]>
AuthorDate: Wed Jun 26 16:16:08 2024 +0800
Update PipeTabletEventTsFileBatch.java
---
.../connector/payload/evolvable/batch/PipeTabletEventTsFileBatch.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/batch/PipeTabletEventTsFileBatch.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/batch/PipeTabletEventTsFileBatch.java
index 784538d81fb..4864a124668 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/batch/PipeTabletEventTsFileBatch.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/batch/PipeTabletEventTsFileBatch.java
@@ -282,8 +282,8 @@ public class PipeTabletEventTsFileBatch extends
PipeTabletEventBatch {
final boolean deleteSuccess = FileUtils.deleteQuietly(sealedFile);
LOGGER.warn(
"Batch id = {}: {} delete the tsfile {} after failed to write
tablets into {}. {}",
- deleteSuccess ? "Successfully" : "Failed to",
currentBatchId.get(),
+ deleteSuccess ? "Successfully" : "Failed to",
sealedFile.getPath(),
fileWriter.getIOWriter().getFile().getPath(),
deleteSuccess ? "" : "Maybe the tsfile needs to be deleted
manually.");