From 2f6a8b6b5193624462a0690ffb3ea273926f70b5 Mon Sep 17 00:00:00 2001 From: ChengJie1053 <18033291053@163.com> Date: Tue, 20 Jun 2023 09:55:10 +0800 Subject: [PATCH 1/2] Flink removes useless code --- .../flink/config/FlinkEnvConfiguration.scala | 5 ----- 1 file changed, 5 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 6bdb228191..5ff7ae2a88 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") From e6d09d2d56e833c660f3e7e40bfd74d46cf718d3 Mon Sep 17 00:00:00 2001 From: ChengJie1053 <18033291053@163.com> Date: Tue, 20 Jun 2023 10:24:51 +0800 Subject: [PATCH 2/2] Flink removes useless code --- .../engineconnplugin/flink/factory/FlinkEngineConnFactory.scala | 1 - 1 file changed, 1 deletion(-) 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 599f87e69c..6da745ad98 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)