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