You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ma...@apache.org on 2022/10/14 02:18:38 UTC
[iotdb] branch IOTDB-4584-0.13 created (now b2c023ced1)
This is an automated email from the ASF dual-hosted git repository.
marklau99 pushed a change to branch IOTDB-4584-0.13
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at b2c023ced1 disable chunk size control in writing process
This branch includes the following new commits:
new b2c023ced1 disable chunk size control in writing process
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: disable chunk size control in writing process
Posted by ma...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
marklau99 pushed a commit to branch IOTDB-4584-0.13
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit b2c023ced1fd5b7a4f8d30ad70d58a8437ff522c
Author: Liu Xuxin <li...@outlook.com>
AuthorDate: Fri Oct 14 10:18:21 2022 +0800
disable chunk size control in writing process
---
.../apache/iotdb/db/engine/storagegroup/TsFileProcessor.java | 9 +--------
.../iotdb/db/writelog/recover/TsFileRecoverPerformer.java | 10 +---------
2 files changed, 2 insertions(+), 17 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 b4aa792d43..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
@@ -172,14 +172,7 @@ public class TsFileProcessor {
this.storageGroupName = storageGroupName;
this.tsFileResource = new TsFileResource(tsfile, this);
this.storageGroupInfo = storageGroupInfo;
- this.writer =
- new RestorableTsFileIOWriter(
- tsfile,
- (long)
- (IoTDBDescriptor.getInstance().getConfig().getMemtableSizeThreshold()
- * IoTDBDescriptor.getInstance()
- .getConfig()
- .getChunkMetadataMemorySizeProportion()));
+ this.writer = new RestorableTsFileIOWriter(tsfile);
this.updateLatestFlushTimeCallback = updateLatestFlushTimeCallback;
this.sequence = sequence;
logger.info("create a new tsfile processor {}", tsfile.getAbsolutePath());
diff --git a/server/src/main/java/org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java b/server/src/main/java/org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java
index eeb234d0cc..4d0dbb5f1c 100644
--- a/server/src/main/java/org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java
+++ b/server/src/main/java/org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java
@@ -19,7 +19,6 @@
package org.apache.iotdb.db.writelog.recover;
-import org.apache.iotdb.db.conf.IoTDBDescriptor;
import org.apache.iotdb.db.engine.fileSystem.SystemFileFactory;
import org.apache.iotdb.db.engine.flush.MemTableFlushTask;
import org.apache.iotdb.db.engine.memtable.IMemTable;
@@ -114,14 +113,7 @@ public class TsFileRecoverPerformer {
// remove corrupted part of the TsFile
RestorableTsFileIOWriter restorableTsFileIOWriter = null;
try {
- restorableTsFileIOWriter =
- new RestorableTsFileIOWriter(
- file,
- (long)
- (IoTDBDescriptor.getInstance().getConfig().getMemtableSizeThreshold()
- * IoTDBDescriptor.getInstance()
- .getConfig()
- .getChunkMetadataMemorySizeProportion()));
+ restorableTsFileIOWriter = new RestorableTsFileIOWriter(file);
} catch (NotCompatibleTsFileException e) {
boolean result = file.delete();
logger.warn("TsFile {} is incompatible. Delete it successfully {}", filePath, result);