remove same override

WeDataSphere · Sep 20, 2024 · 0ea7c44 · 0ea7c44
1 parent 6f14249
commit 0ea7c44
Showing 1 changed file with 0 additions and 13 deletions.
diff --git a/.../scala/org/apache/linkis/engineconnplugin/flink/launch/FlinkEngineConnLaunchBuilder.scala b/.../scala/org/apache/linkis/engineconnplugin/flink/launch/FlinkEngineConnLaunchBuilder.scala
@@ -108,19 +108,6 @@ class FlinkEngineConnLaunchBuilder extends JavaProcessEngineConnLaunchBuilder {
     environment
   }
 
-  override def getEnvironment(implicit
-      engineConnBuildRequest: EngineConnBuildRequest
-  ): util.Map[String, String] = {
-    val environment = new util.HashMap[String, String]
-    addPathToClassPath(environment, variable(PWD))
-    val linkisEnvironment = super.getEnvironment
-    val linkisClassPath = linkisEnvironment.get(Environment.CLASSPATH.toString)
-    val v = environment.get(Environment.CLASSPATH.toString) + CLASS_PATH_SEPARATOR + linkisClassPath
-    environment.put(Environment.CLASSPATH.toString, v)
-    logger.info(environment.asScala.map(e => s"${e._1}->${e._2}").mkString(","))
-    environment
-  }
-
   private def contentToBmlResource(userName: String, content: String): BmlResource = {
     val contentMap = JsonUtils.jackson.readValue(content, classOf[util.Map[String, Object]])
     contentToBmlResource(userName, contentMap)