diff --git a/linkis-engineconn-plugins/flink/flink-core/src/main/scala/org/apache/linkis/engineconnplugin/flink/launch/FlinkEngineConnLaunchBuilder.scala b/linkis-engineconn-plugins/flink/flink-core/src/main/scala/org/apache/linkis/engineconnplugin/flink/launch/FlinkEngineConnLaunchBuilder.scala
index a4a77e9a01..13a5bae4d5 100644
--- a/linkis-engineconn-plugins/flink/flink-core/src/main/scala/org/apache/linkis/engineconnplugin/flink/launch/FlinkEngineConnLaunchBuilder.scala
+++ b/linkis-engineconn-plugins/flink/flink-core/src/main/scala/org/apache/linkis/engineconnplugin/flink/launch/FlinkEngineConnLaunchBuilder.scala
@@ -109,19 +109,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)