Flink removes useless code (#4677)

* Flink removes useless code
apache · Jun 20, 2023 · d8c018f · d8c018f
1 parent cd59dba
commit d8c018f
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 6 deletions.
diff --git a/...rc/main/scala/org/apache/linkis/engineconnplugin/flink/config/FlinkEnvConfiguration.scala b/...rc/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/.../main/scala/org/apache/linkis/engineconnplugin/flink/factory/FlinkEngineConnFactory.scala b/.../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)