(fluss) branch main updated: [hotfix] The DiscardingSink operator after LakeCommitter should always be with parallelism 1 (#1356)

[yuxia]

This is an automated email from the ASF dual-hosted git repository.

yuxia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 165ec7f9 [hotfix] The DiscardingSink operator after LakeCommitter 
should always be with parallelism 1 (#1356)
165ec7f9 is described below

commit 165ec7f90e1e210fa789c49390295fd969d279cf
Author: yuxia Luo <luoyu...@alumni.sjtu.edu.cn>
AuthorDate: Thu Jul 17 16:29:30 2025 +0800

    [hotfix] The DiscardingSink operator after LakeCommitter should always be 
with parallelism 1 (#1356)
---
 .../java/com/alibaba/fluss/flink/tiering/LakeTieringJobBuilder.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/tiering/LakeTieringJobBuilder.java
 
b/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/tiering/LakeTieringJobBuilder.java
index ca74b895..7876e8d1 100644
--- 
a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/tiering/LakeTieringJobBuilder.java
+++ 
b/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/tiering/LakeTieringJobBuilder.java
@@ -102,7 +102,9 @@ public class LakeTieringJobBuilder {
                         new TieringCommitOperatorFactory(flussConfig, 
lakeTieringFactory))
                 .setParallelism(1)
                 .setMaxParallelism(1)
-                .sinkTo(new DiscardingSink());
+                .sinkTo(new DiscardingSink())
+                .name("end")
+                .setParallelism(1);
         String jobName =
                 env.getConfiguration()
                         .getOptional(PipelineOptions.NAME)