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

benjobs pushed a commit to branch dev-2.1.3
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev-2.1.3 by this push:
     new 157f33ea1 [Improve] import package improve
157f33ea1 is described below

commit 157f33ea15e5e6e7779d4deddd20e9df060e3211
Author: benjobs <[email protected]>
AuthorDate: Fri Dec 22 11:05:29 2023 +0800

    [Improve] import package improve
---
 .../org/apache/streampark/flink/client/trait/YarnClientTrait.scala    | 4 ----
 1 file changed, 4 deletions(-)

diff --git 
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/YarnClientTrait.scala
 
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/YarnClientTrait.scala
index 0021184b1..32991b109 100644
--- 
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/YarnClientTrait.scala
+++ 
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/YarnClientTrait.scala
@@ -17,7 +17,6 @@
 
 package org.apache.streampark.flink.client.`trait`
 
-import org.apache.streampark.common.enums.ApplicationType
 import org.apache.streampark.common.util.Utils
 import org.apache.streampark.flink.client.bean._
 
@@ -40,12 +39,9 @@ import scala.util.Try
 trait YarnClientTrait extends FlinkClientTrait {
 
   override def setConfig(submitRequest: SubmitRequest, flinkConfig: 
Configuration): Unit = {
-    // yarn application name
     flinkConfig
       .safeSet(YarnConfigOptions.APPLICATION_NAME, 
submitRequest.effectiveAppName)
-      // yarn application Type
       .safeSet(YarnConfigOptions.APPLICATION_TYPE, 
submitRequest.applicationType.getName)
-      // yarn application Tag
       .safeSet(YarnConfigOptions.APPLICATION_TAGS, "streampark")
   }
 

Reply via email to