fix compile

apache · Jan 22, 2025 · 14c7b46 · 14c7b46
1 parent 874a6b7
commit 14c7b46
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../common/src/main/java/org/apache/celeborn/plugin/flink/client/FlinkShuffleClientImpl.java b/.../common/src/main/java/org/apache/celeborn/plugin/flink/client/FlinkShuffleClientImpl.java
@@ -283,7 +283,7 @@ public ReduceFileGroups updateFileGroup(
           // refresh file groups
           Tuple3<ReduceFileGroups, String, Exception> fileGroups =
               loadFileGroupInternal(shuffleId, isSegmentGranularityVisible);
-          ReduceFileGroups newGroups = fileGroups._1;
+          ReduceFileGroups newGroups = fileGroups._1();
           if (newGroups == null) {
             throw new CelebornIOException(
                 loadFileGroupException(shuffleId, partitionId, fileGroups._2()));