Skip to content

Commit 1bf23b1

Browse files
authored
[flink] fix de-merge-into runtimeContext may throw NoSuchMethod error (#7607)
1 parent f5b9dec commit 1bf23b1

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/dataevolution/MergeIntoUpdateChecker.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
import org.apache.paimon.data.BinaryRow;
2424
import org.apache.paimon.flink.sink.Committable;
2525
import org.apache.paimon.flink.utils.BoundedOneInputOperator;
26+
import org.apache.paimon.flink.utils.RuntimeContextUtils;
2627
import org.apache.paimon.index.GlobalIndexMeta;
2728
import org.apache.paimon.index.IndexFileMeta;
2829
import org.apache.paimon.io.CompactIncrement;
@@ -70,7 +71,7 @@ public void open() throws Exception {
7071
affectedPartitions = new HashSet<>();
7172

7273
Preconditions.checkState(
73-
getRuntimeContext().getTaskInfo().getNumberOfParallelSubtasks() == 1,
74+
RuntimeContextUtils.getNumberOfParallelSubtasks(getRuntimeContext()) == 1,
7475
"Parallelism of MergeIntoUpdateChecker must be 1.");
7576
}
7677

0 commit comments

Comments
 (0)