Caizhi Weng created FLINK-29916: ----------------------------------- Summary: Levels in Table Store may mistakenly ignore level 0 files when two files have the same sequence number Key: FLINK-29916 URL: https://issues.apache.org/jira/browse/FLINK-29916 Project: Flink Issue Type: Bug Components: Table Store Affects Versions: table-store-0.3.0, table-store-0.2.2 Reporter: Caizhi Weng Fix For: table-store-0.3.0, table-store-0.2.2
Current constructor of {{Levels}} class contains the following code: {code:java} this.level0 = new TreeSet<>(Comparator.comparing(DataFileMeta::maxSequenceNumber).reversed()); {code} However when two or more jobs writing the same bucket, they may produce files containing the same sequence number. If two files have the same {{maxSequenceNumber}}, one of them will be mistakenly ignored by {{TreeSet}}. -- This message was sent by Atlassian Jira (v8.20.10#820010)