fix comment

apache · Apr 19, 2024 · fc79873 · fc79873
1 parent ad18c74
commit fc79873
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...ink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java b/...ink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java
@@ -106,8 +106,7 @@ public void initializeState(StateInitializationContext context) throws Exception
         super.initializeState(context);
 
         Preconditions.checkArgument(
-                !forceSingleParallelism
-                        || getRuntimeContext().getTaskInfo().getNumberOfParallelSubtasks() == 1,
+                !forceSingleParallelism || getRuntimeContext().getNumberOfParallelSubtasks() == 1,
                 "Committer Operator parallelism in paimon MUST be one.");
 
         this.currentWatermark = Long.MIN_VALUE;