Skip to content

Commit cf868fd

Browse files
committed
fix tag recover temporarily
1 parent 2fb742f commit cf868fd

1 file changed

Lines changed: 11 additions & 0 deletions

File tree

server/src/main/java/org/apache/iotdb/db/metadata/MManager.java

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -300,6 +300,17 @@ public synchronized void init() {
300300

301301
logWriter = new MLogWriter(config.getSchemaDir(), MetadataConstant.METADATA_LOG);
302302
logWriter.setLogNum(lineNumber);
303+
304+
// todo fix me by refactoring tag recover
305+
for (PartialPath path : mtree.getMeasurementPaths(new PartialPath("root.**"))) {
306+
IMeasurementMNode measurementMNode = mtree.getMeasurementMNode(path);
307+
if (measurementMNode.getOffset() != -1) {
308+
tagManager.recoverIndex(measurementMNode.getOffset(), measurementMNode);
309+
} else {
310+
mtree.unPinMNode(measurementMNode);
311+
}
312+
}
313+
303314
isRecovering = false;
304315
} catch (MetadataException | IOException e) {
305316
logger.error(

0 commit comments

Comments
 (0)