(amoro) branch master updated: [AMORO-3128] Make yarn application name for flink optimizer more meaningful (#3129)

[baiyangtx]

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

baiyangtx pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/amoro.git


The following commit(s) were added to refs/heads/master by this push:
     new 2bf68a19d [AMORO-3128] Make yarn application name for flink optimizer 
more meaningful (#3129)
2bf68a19d is described below

commit 2bf68a19d2eda1dbeb6f6483ec23d7fd5d859d28
Author: Congxian Qiu <qcx978132...@gmail.com>
AuthorDate: Sat Aug 24 14:08:24 2024 +0800

    [AMORO-3128] Make yarn application name for flink optimizer more meaningful 
(#3129)
---
 .../org/apache/amoro/server/manager/FlinkOptimizerContainer.java    | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/amoro-ams/amoro-ams-server/src/main/java/org/apache/amoro/server/manager/FlinkOptimizerContainer.java
 
b/amoro-ams/amoro-ams-server/src/main/java/org/apache/amoro/server/manager/FlinkOptimizerContainer.java
index 593f3ae92..27dec48a0 100644
--- 
a/amoro-ams/amoro-ams-server/src/main/java/org/apache/amoro/server/manager/FlinkOptimizerContainer.java
+++ 
b/amoro-ams/amoro-ams-server/src/main/java/org/apache/amoro/server/manager/FlinkOptimizerContainer.java
@@ -231,6 +231,10 @@ public class FlinkOptimizerContainer extends 
AbstractResourceContainer {
         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) {
@@ -650,6 +654,8 @@ public class FlinkOptimizerContainer extends 
AbstractResourceContainer {
     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 {