This is an automated email from the ASF dual-hosted git repository. yuzelin pushed a commit to branch release-1.4 in repository https://gitbox.apache.org/repos/asf/paimon.git
commit 8fb5b3e3bd679d33430f7fa034d78acf54311463 Author: Faiz <[email protected]> AuthorDate: Tue Apr 7 21:53:14 2026 +0800 [flink] fix de-merge-into runtimeContext may throw NoSuchMethod error (#7607) --- .../org/apache/paimon/flink/dataevolution/MergeIntoUpdateChecker.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/dataevolution/MergeIntoUpdateChecker.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/dataevolution/MergeIntoUpdateChecker.java index 94392a84ec..8b1122382a 100644 --- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/dataevolution/MergeIntoUpdateChecker.java +++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/dataevolution/MergeIntoUpdateChecker.java @@ -23,6 +23,7 @@ import org.apache.paimon.Snapshot; import org.apache.paimon.data.BinaryRow; import org.apache.paimon.flink.sink.Committable; import org.apache.paimon.flink.utils.BoundedOneInputOperator; +import org.apache.paimon.flink.utils.RuntimeContextUtils; import org.apache.paimon.index.GlobalIndexMeta; import org.apache.paimon.index.IndexFileMeta; import org.apache.paimon.io.CompactIncrement; @@ -70,7 +71,7 @@ public class MergeIntoUpdateChecker extends BoundedOneInputOperator<Committable, affectedPartitions = new HashSet<>(); Preconditions.checkState( - getRuntimeContext().getTaskInfo().getNumberOfParallelSubtasks() == 1, + RuntimeContextUtils.getNumberOfParallelSubtasks(getRuntimeContext()) == 1, "Parallelism of MergeIntoUpdateChecker must be 1."); }
