Skip to content

Commit cb24115

Browse files
authored
[fix](compile) fe cannot compile in idea (#32955)
1 parent affee13 commit cb24115

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

fe/fe-core/src/main/java/org/apache/doris/transaction/PublishVersionDaemon.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
import org.apache.doris.catalog.Partition;
2424
import org.apache.doris.common.Config;
2525
import org.apache.doris.common.MetaNotFoundException;
26+
import org.apache.doris.common.Pair;
2627
import org.apache.doris.common.util.DebugPointUtil;
2728
import org.apache.doris.common.util.MasterDaemon;
2829
import org.apache.doris.metric.MetricRepo;
@@ -45,7 +46,6 @@
4546
import java.util.Collections;
4647
import java.util.List;
4748
import java.util.Map;
48-
import java.util.Map.Entry;
4949
import java.util.Set;
5050
import java.util.stream.Collectors;
5151
import java.util.stream.Stream;
@@ -225,8 +225,8 @@ private Map<Long, Set<Long>> getBaseTabletIdsForEachBe(TransactionState transact
225225
.flatMap(Collection::stream)
226226
.flatMap(tablet ->
227227
tablet.getBackendIds()
228-
.stream().map(backendId -> Map.entry(backendId, tablet.getId())))
229-
.collect(Collectors.groupingBy(Entry::getKey,
230-
Collectors.mapping(Entry::getValue, Collectors.toSet())));
228+
.stream().map(backendId -> Pair.of(backendId, tablet.getId())))
229+
.collect(Collectors.groupingBy(p -> p.first,
230+
Collectors.mapping(p -> p.second, Collectors.toSet())));
231231
}
232232
}

0 commit comments

Comments
 (0)