This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 1bf23b1e5d [flink] fix de-merge-into runtimeContext may throw
NoSuchMethod error (#7607)
1bf23b1e5d is described below
commit 1bf23b1e5d98ce33c3ff32076ed9ae616b819dcf
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.");
}
