This is an automated email from the ASF dual-hosted git repository.
ron pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new c55909c9e35 [hotfix][state] Remove duplicate comparing about intersect
group range. (#26544)
c55909c9e35 is described below
commit c55909c9e3567c761218f3aa6e2cd4994cc394bd
Author: wangxinglong <[email protected]>
AuthorDate: Mon May 19 10:21:29 2025 +0800
[hotfix][state] Remove duplicate comparing about intersect group range.
(#26544)
---
.../apache/flink/state/rocksdb/RocksDBIncrementalCheckpointUtils.java | 1 -
1 file changed, 1 deletion(-)
diff --git
a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/RocksDBIncrementalCheckpointUtils.java
b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/RocksDBIncrementalCheckpointUtils.java
index 65210c92ee9..014ef9ef050 100644
---
a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/RocksDBIncrementalCheckpointUtils.java
+++
b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/RocksDBIncrementalCheckpointUtils.java
@@ -115,7 +115,6 @@ public class RocksDBIncrementalCheckpointUtils {
public int compareTo(@Nullable Score other) {
return Comparator.nullsFirst(
Comparator.comparing(Score::getIntersectGroupRange)
-
.thenComparing(Score::getIntersectGroupRange)
.thenComparing(Score::getOverlapFraction))
.compare(this, other);
}