(fluss) branch main updated: [lake] Tiering job name as per lake format (#2003)

[jark]

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

jark 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 ae84521aa [lake] Tiering job name as per lake format (#2003)
ae84521aa is described below

commit ae84521aaaef5448a0bc5a63fc83e6ca536ca452
Author: MehulBatra <66407733+mehulba...@users.noreply.github.com>
AuthorDate: Sat Nov 22 21:22:14 2025 +0530

    [lake] Tiering job name as per lake format (#2003)
---
 .../main/java/org/apache/fluss/flink/tiering/LakeTieringJobBuilder.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/LakeTieringJobBuilder.java
 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/LakeTieringJobBuilder.java
index d963dff99..85eed128c 100644
--- 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/LakeTieringJobBuilder.java
+++ 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/LakeTieringJobBuilder.java
@@ -108,7 +108,7 @@ public class LakeTieringJobBuilder {
         String jobName =
                 env.getConfiguration()
                         .getOptional(PipelineOptions.NAME)
-                        .orElse(DEFAULT_TIERING_SERVICE_JOB_NAME);
+                        .orElse(DEFAULT_TIERING_SERVICE_JOB_NAME + " - " + 
dataLakeFormat);
 
         return env.executeAsync(jobName);
     }