From 14c7b4689520e86ea06c8ce499a1e94ef8486f00 Mon Sep 17 00:00:00 2001 From: "Wang, Fei" Date: Wed, 22 Jan 2025 21:19:42 +0800 Subject: [PATCH] fix compile --- .../celeborn/plugin/flink/client/FlinkShuffleClientImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client/FlinkShuffleClientImpl.java b/client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client/FlinkShuffleClientImpl.java index 42c00f16c54..7c909c7476b 100644 --- a/client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client/FlinkShuffleClientImpl.java +++ b/client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client/FlinkShuffleClientImpl.java @@ -283,7 +283,7 @@ public ReduceFileGroups updateFileGroup( // refresh file groups Tuple3 fileGroups = loadFileGroupInternal(shuffleId, isSegmentGranularityVisible); - ReduceFileGroups newGroups = fileGroups._1; + ReduceFileGroups newGroups = fileGroups._1(); if (newGroups == null) { throw new CelebornIOException( loadFileGroupException(shuffleId, partitionId, fileGroups._2()));