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")
}