[lake] Tiering job name as per lake format (apache#2003)

MehulBatra · web-flow · commit ae84521aaaef · 2025-11-22T23:52:14.000+08:00
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
@@ -108,7 +108,7 @@ public JobClient build() throws Exception {
         String jobName =
                 env.getConfiguration()
                         .getOptional(PipelineOptions.NAME)
-                        .orElse(DEFAULT_TIERING_SERVICE_JOB_NAME);
+                        .orElse(DEFAULT_TIERING_SERVICE_JOB_NAME + " - " + dataLakeFormat);
 
         return env.executeAsync(jobName);
     }

Original file line number	Diff line number	Diff line change
`@@ -108,7 +108,7 @@ public JobClient build() throws Exception {`
`108`	`108`	`String jobName =`
`109`	`109`	`env.getConfiguration()`
`110`	`110`	`.getOptional(PipelineOptions.NAME)`
`111`		`- .orElse(DEFAULT_TIERING_SERVICE_JOB_NAME);`
	`111`	`+ .orElse(DEFAULT_TIERING_SERVICE_JOB_NAME + " - " + dataLakeFormat);`
`112`	`112`
`113`	`113`	`return env.executeAsync(jobName);`
`114`	`114`	`}`