Skip to content

Commit 52adf9a

Browse files
Load: fix data loss when loading different files with same name in the same directory (#15527) (#15543)
1 parent e3dda34 commit 52adf9a

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/LoadTsFileAnalyzer.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -455,10 +455,10 @@ private void doAnalyzeSingleFile(
455455
while (timeseriesMetadataIterator.hasNext()) {
456456
final Map<IDeviceID, List<TimeseriesMetadata>> device2TimeseriesMetadata =
457457
timeseriesMetadataIterator.next();
458-
if (!tsFileResource.resourceFileExists()) {
459-
TsFileResourceUtils.updateTsFileResource(device2TimeseriesMetadata, tsFileResource);
460-
schemaAutoCreatorAndVerifier.setCurrentTimeIndex(tsFileResource.getTimeIndex());
461-
}
458+
// Update time index no matter if resource file exists or not, because resource file may be
459+
// untrusted
460+
TsFileResourceUtils.updateTsFileResource(device2TimeseriesMetadata, tsFileResource);
461+
schemaAutoCreatorAndVerifier.setCurrentTimeIndex(tsFileResource.getTimeIndex());
462462

463463
if (isAutoCreateSchemaOrVerifySchemaEnabled) {
464464
schemaAutoCreatorAndVerifier.autoCreateAndVerify(reader, device2TimeseriesMetadata);

0 commit comments

Comments
 (0)