This is an automated email from the ASF dual-hosted git repository. marklau99 pushed a commit to branch IOTDB-4579 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c425e521f769010d3ee941b18e46208845aeb673 Author: Liu Xuxin <[email protected]> AuthorDate: Fri Oct 7 15:28:53 2022 +0800 remove the update of target file start time and end time in the end of cross space compaction --- .../db/engine/compaction/CompactionUtils.java | 26 ---------------------- 1 file changed, 26 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionUtils.java b/server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionUtils.java index 9ee9d5cd09..dc2dfa92cb 100644 --- a/server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionUtils.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionUtils.java @@ -43,7 +43,6 @@ import org.apache.iotdb.db.service.IoTDB; import org.apache.iotdb.db.utils.QueryUtils; import org.apache.iotdb.tsfile.common.constant.TsFileConstant; import org.apache.iotdb.tsfile.exception.write.WriteProcessException; -import org.apache.iotdb.tsfile.file.metadata.TimeseriesMetadata; import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType; import org.apache.iotdb.tsfile.fileSystem.FSFactoryProducer; import org.apache.iotdb.tsfile.read.common.BatchData; @@ -51,7 +50,6 @@ import org.apache.iotdb.tsfile.read.reader.IBatchReader; import org.apache.iotdb.tsfile.utils.Pair; import org.apache.iotdb.tsfile.write.schema.IMeasurementSchema; import org.apache.iotdb.tsfile.write.schema.MeasurementSchema; -import org.apache.iotdb.tsfile.write.writer.TsFileIOWriter; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -114,7 +112,6 @@ public class CompactionUtils { } compactionWriter.endFile(); - updateDeviceStartTimeAndEndTime(targetFileResources, compactionWriter); updatePlanIndexes(targetFileResources, seqFileResources, unseqFileResources); } finally { QueryResourceManager.getInstance().endQuery(queryId); @@ -265,29 +262,6 @@ public class CompactionUtils { } } - private static void updateDeviceStartTimeAndEndTime( - List<TsFileResource> targetResources, AbstractCompactionWriter compactionWriter) { - List<TsFileIOWriter> targetFileWriters = compactionWriter.getFileIOWriter(); - for (int i = 0; i < targetFileWriters.size(); i++) { - TsFileIOWriter fileIOWriter = targetFileWriters.get(i); - TsFileResource fileResource = targetResources.get(i); - // The tmp target file may does not have any data points written due to the existence of the - // mods file, and it will be deleted after compaction. So skip the target file that has been - // deleted. - if (!fileResource.getTsFile().exists()) { - continue; - } - for (Map.Entry<String, List<TimeseriesMetadata>> entry : - fileIOWriter.getDeviceTimeseriesMetadataMap().entrySet()) { - String device = entry.getKey(); - for (TimeseriesMetadata timeseriesMetadata : entry.getValue()) { - fileResource.updateStartTime(device, timeseriesMetadata.getStatistics().getStartTime()); - fileResource.updateEndTime(device, timeseriesMetadata.getStatistics().getEndTime()); - } - } - } - } - private static void updatePlanIndexes( List<TsFileResource> targetResources, List<TsFileResource> seqResources,
