Skip to content

Commit fd50711

Browse files
committed
[minor][lake] Set default name for flink tiering service job
1 parent 0cb955c commit fd50711

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/tiering/LakeTieringJobBuilder.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,8 @@
4242
/** The builder to build Flink lake tiering job. */
4343
public class LakeTieringJobBuilder {
4444

45+
private static final String DEFAULT_TIERING_SERVICE_JOB_NAME = "Fluss_Tiering_Service_Job";
46+
4547
private final StreamExecutionEnvironment env;
4648
private final Configuration flussConfig;
4749
private final Configuration dataLakeConfig;
@@ -107,6 +109,6 @@ public JobClient build() throws Exception {
107109
.setMaxParallelism(1)
108110
.sinkTo(new DiscardingSink());
109111

110-
return env.executeAsync();
112+
return env.executeAsync(DEFAULT_TIERING_SERVICE_JOB_NAME);
111113
}
112114
}

0 commit comments

Comments
 (0)