You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by zy...@apache.org on 2022/07/29 13:03:38 UTC
[iotdb] branch rel/0.13 updated: [To rel/0.13]Fix mLogParser and mLogTxtWriter #6839
This is an automated email from the ASF dual-hosted git repository.
zyk 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 f14d0837fc [To rel/0.13]Fix mLogParser and mLogTxtWriter #6839
f14d0837fc is described below
commit f14d0837fc3882c1dd488e4d6330c8a9e5917253
Author: ZhaoXin <x_...@163.com>
AuthorDate: Fri Jul 29 21:03:33 2022 +0800
[To rel/0.13]Fix mLogParser and mLogTxtWriter #6839
[To rel/0.13]Fix mLogParser and mLogTxtWriter #6839
---
.../main/java/org/apache/iotdb/db/metadata/logfile/MLogTxtWriter.java | 4 ++++
server/src/main/java/org/apache/iotdb/db/tools/mlog/MLogParser.java | 1 +
2 files changed, 5 insertions(+)
diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogTxtWriter.java b/server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogTxtWriter.java
index 7b7438df57..0b3e1142e9 100644
--- a/server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogTxtWriter.java
+++ b/server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogTxtWriter.java
@@ -419,7 +419,9 @@ public class MLogTxtWriter implements AutoCloseable {
// OperationType,templateName,isAlign[,measurementPath,dataType,encoding,compressor]
StringBuilder buf = new StringBuilder();
buf.append(MetadataOperationType.APPEND_TEMPLATE);
+ buf.append(",");
buf.append(plan.getName());
+ buf.append(",");
buf.append(plan.isAligned());
for (int i = 0; i < plan.getMeasurements().size(); i++) {
buf.append(
@@ -441,8 +443,10 @@ public class MLogTxtWriter implements AutoCloseable {
// OperationType,templateName[,measurementPath]
StringBuilder buf = new StringBuilder();
buf.append(MetadataOperationType.PRUNE_TEMPLATE);
+ buf.append(",");
buf.append(plan.getName());
for (int i = 0; i < plan.getPrunedMeasurements().size(); i++) {
+ buf.append(",");
buf.append(plan.getPrunedMeasurements().get(i));
}
buf.append(LINE_SEPARATOR);
diff --git a/server/src/main/java/org/apache/iotdb/db/tools/mlog/MLogParser.java b/server/src/main/java/org/apache/iotdb/db/tools/mlog/MLogParser.java
index ee310272c0..026855546b 100644
--- a/server/src/main/java/org/apache/iotdb/db/tools/mlog/MLogParser.java
+++ b/server/src/main/java/org/apache/iotdb/db/tools/mlog/MLogParser.java
@@ -227,6 +227,7 @@ public class MLogParser {
break;
case PRUNE_TEMPLATE:
mLogTxtWriter.pruneTemplate((PruneTemplatePlan) plan);
+ break;
case SET_TEMPLATE:
mLogTxtWriter.setTemplate((SetTemplatePlan) plan);
break;