(paimon) branch master updated: [flink] fix CommitterOperator chain value when sink.committer-operator-chaining is false (#3779)

[lzljs3620320]

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 f0a082c0d [flink] fix CommitterOperator chain value when 
sink.committer-operator-chaining is false (#3779)
f0a082c0d is described below

commit f0a082c0d1bb8fd687f3f8b5a35f762f75908495
Author: wangwj <hongli....@gmail.com>
AuthorDate: Thu Jul 18 22:45:15 2024 +0800

    [flink] fix CommitterOperator chain value when 
sink.committer-operator-chaining is false (#3779)
---
 .../src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java
index 5e500963e..2ec90b8c6 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/CommitterOperator.java
@@ -121,7 +121,7 @@ public class CommitterOperator<CommitT, GlobalCommitT> 
extends AbstractStreamOpe
         this.committerFactory = checkNotNull(committerFactory);
         this.committableStateManager = committableStateManager;
         this.endInputWatermark = endInputWatermark;
-        setChainingStrategy(chaining ? ChainingStrategy.ALWAYS : 
ChainingStrategy.NEVER);
+        setChainingStrategy(chaining ? ChainingStrategy.ALWAYS : 
ChainingStrategy.HEAD);
     }
 
     @Override