[lake/flink][minor] Avoid duplicated job execution

Author: leonardBang

fluss-flink/fluss-flink-tiering/src/main/java/com/alibaba/fluss/flink/tiering/FlussLakeTieringEntrypoint.java

@@ -64,14 +64,13 @@ public static void main(String[] args) throws Exception {
                 StreamExecutionEnvironment.getExecutionEnvironment();
 
         // build lake tiering job
-        LakeTieringJobBuilder.newBuilder(
-                        execEnv,
-                        Configuration.fromMap(flussConfigMap),
-                        Configuration.fromMap(lakeConfigMap),
-                        dataLake)
-                .build();
-
-        JobClient jobClient = execEnv.executeAsync();
+        JobClient jobClient =
+                LakeTieringJobBuilder.newBuilder(
+                                execEnv,
+                                Configuration.fromMap(flussConfigMap),
+                                Configuration.fromMap(lakeConfigMap),
+                                dataLake)
+                        .build();
 
         System.out.printf(
                 "Starting data tiering service from Fluss to %s, jobId is %s.....%n",

fluss-lake/fluss-lake-paimon/src/test/java/com/alibaba/fluss/lake/paimon/testutils/FlinkPaimonTieringTestBase.java

@@ -126,7 +126,7 @@ public void beforeEach() {
 
     protected JobClient buildTieringJob(StreamExecutionEnvironment execEnv) throws Exception {
         Configuration flussConfig = new Configuration(clientConf);
-        flussConfig.set(POLL_TIERING_TABLE_INTERVAL, Duration.ofMillis(500));
+        flussConfig.set(POLL_TIERING_TABLE_INTERVAL, Duration.ofMillis(500L));
         return LakeTieringJobBuilder.newBuilder(
                         execEnv,
                         flussConfig,