Skip to content

Commit

Permalink
[AMORO-3128] Make yarn application name for flink optimizer more mean…
Browse files Browse the repository at this point in the history
…ingful (#3129)

(cherry picked from commit 2bf68a1)
Signed-off-by: zhoujinsong <zhoujinsong0505@163.com>
  • Loading branch information
klion26 authored and zhoujinsong committed Oct 11, 2024
1 parent f0400a4 commit a26da28
Showing 1 changed file with 6 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -243,6 +243,10 @@ protected String buildOptimizerStartupArgsString(Resource resource) {
FlinkConfKeys.JOB_MANAGER_TOTAL_PROCESS_MEMORY, jobManagerMemory + "m");
resourceFlinkConf.putToOptions(
FlinkConfKeys.TASK_MANAGER_TOTAL_PROCESS_MEMORY, taskManagerMemory + "m");
resourceFlinkConf.putToOptions(
FlinkConfKeys.YARN_APPLICATION_JOB_NAME,
String.join(
"-", "Amoro-flink-optimizer", resource.getGroupName(), resource.getResourceId()));

String flinkAction = target.isApplicationMode() ? "run-application" : "run";
if (Target.KUBERNETES_APPLICATION == target) {
Expand Down Expand Up @@ -619,6 +623,8 @@ public static class FlinkConfKeys {
public static final String KUBERNETES_CLUSTER_ID = "kubernetes.cluster-id";
public static final String KUBERNETES_TASKMANAGER_LABELS = "kubernetes.taskmanager.labels";
public static final String KUBERNETES_JOBMANAGER_LABELS = "kubernetes.jobmanager.labels";

public static final String YARN_APPLICATION_JOB_NAME = "yarn.application.name";
}

public static class FlinkConf {
Expand Down

0 comments on commit a26da28

Please sign in to comment.