diff --git a/streamx-plugin/streamx-flink-sqlcli/pom.xml b/streamx-plugin/streamx-flink-sqlcli/pom.xml
index 319d097866..2f17d74b49 100644
--- a/streamx-plugin/streamx-flink-sqlcli/pom.xml
+++ b/streamx-plugin/streamx-flink-sqlcli/pom.xml
@@ -11,28 +11,6 @@
StreamX : Flink SQL Cli
-
-
- org.scala-lang
- scala-library
- ${scala.version}
- provided
-
-
-
- org.scala-lang
- scala-compiler
- ${scala.version}
- provided
-
-
-
- org.scala-lang
- scala-reflect
- ${scala.version}
- provided
-
-
com.beachape
enumeratum_${scala.binary.version}
diff --git a/streamx-plugin/streamx-flink-submit/src/main/scala/com/streamxhub/streamx/flink/submit/trait/FlinkSubmitTrait.scala b/streamx-plugin/streamx-flink-submit/src/main/scala/com/streamxhub/streamx/flink/submit/trait/FlinkSubmitTrait.scala
index 0af81dd899..b57e5db3df 100644
--- a/streamx-plugin/streamx-flink-submit/src/main/scala/com/streamxhub/streamx/flink/submit/trait/FlinkSubmitTrait.scala
+++ b/streamx-plugin/streamx-flink-submit/src/main/scala/com/streamxhub/streamx/flink/submit/trait/FlinkSubmitTrait.scala
@@ -20,6 +20,7 @@
*/
package com.streamxhub.streamx.flink.submit.`trait`
+import com.streamxhub.streamx.common.conf.ConfigConst
import com.streamxhub.streamx.common.conf.ConfigConst._
import com.streamxhub.streamx.common.util.{HdfsUtils, Logger, Utils}
import com.streamxhub.streamx.flink.common.conf.FlinkRunOption
@@ -66,7 +67,7 @@ trait FlinkSubmitTrait extends Logger {
flinkHdfsHome,
flinkHdfsLibs = new Path(s"$flinkHdfsHome/lib"),
flinkHdfsPlugins = new Path(s"$flinkHdfsHome/plugins"),
- flinkHdfsJars = new Path(s"$flinkHdfsHome/jars"),
+ flinkHdfsJars = new Path(APP_JARS),
streamxPlugin = new Path(s"${HdfsUtils.getDefaultFS}$APP_PLUGINS"),
flinkYaml = HdfsUtils.read(s"$flinkHdfsHome/conf/flink-conf.yaml"),
flinkHdfsDistJar = new File(s"$FLINK_HOME/lib").list().filter(_.matches("flink-dist_.*\\.jar")) match {