You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by pe...@apache.org on 2023/06/20 06:40:45 UTC
[linkis] branch dev-1.4.0 updated: Flink removes useless code (#4677)
This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a commit to branch dev-1.4.0
in repository https://gitbox.apache.org/repos/asf/linkis.git
The following commit(s) were added to refs/heads/dev-1.4.0 by this push:
new d8c018f12 Flink removes useless code (#4677)
d8c018f12 is described below
commit d8c018f1247137dcc86fb82e6a5d5a1a17161a48
Author: ChengJie1053 <18...@163.com>
AuthorDate: Tue Jun 20 14:40:39 2023 +0800
Flink removes useless code (#4677)
* Flink removes useless code
---
.../linkis/engineconnplugin/flink/config/FlinkEnvConfiguration.scala | 5 -----
.../engineconnplugin/flink/factory/FlinkEngineConnFactory.scala | 1 -
2 files changed, 6 deletions(-)
diff --git a/linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/config/FlinkEnvConfiguration.scala b/linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/config/FlinkEnvConfiguration.scala
index 6bdb22819..5ff7ae2a8 100644
--- a/linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/config/FlinkEnvConfiguration.scala
+++ b/linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/config/FlinkEnvConfiguration.scala
@@ -22,11 +22,6 @@ import org.apache.linkis.engineconnplugin.flink.client.config.entries.ExecutionE
object FlinkEnvConfiguration {
- val SPARK_LIB_PATH = CommonVars(
- "spark.lib.path",
- CommonVars("SPARK_HOME", "/appcom/Install/spark").getValue + "/jars"
- )
-
val FLINK_HOME_ENV = "FLINK_HOME"
val FLINK_CONF_DIR_ENV = "FLINK_CONF_DIR"
val FLINK_VERSION = CommonVars("flink.version", "1.12.2")
diff --git a/linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/factory/FlinkEngineConnFactory.scala b/linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/factory/FlinkEngineConnFactory.scala
index 599f87e69..6da745ad9 100644
--- a/linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/factory/FlinkEngineConnFactory.scala
+++ b/linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/factory/FlinkEngineConnFactory.scala
@@ -137,7 +137,6 @@ class FlinkEngineConnFactory extends MultiExecutorEngineConnFactory with Logging
if (flinkProvidedLibPathList != null && flinkProvidedLibPathList.size() > 0) {
providedLibDirList.addAll(flinkProvidedLibPathList)
}
- // if(StringUtils.isNotBlank(flinkLibRemotePath)) providedLibDirList.add(flinkLibRemotePath)
flinkConfig.set(YarnConfigOptions.PROVIDED_LIB_DIRS, providedLibDirList)
// construct jar-dependencies
flinkConfig.set(YarnConfigOptions.SHIP_FILES, context.getShipDirs)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org