From 2a33932d7ce0c9ceee8a3504e252e1db38343692 Mon Sep 17 00:00:00 2001
From: benjobs <benjobs@qq.com>
Date: Fri, 16 Apr 2021 22:50:04 +0800
Subject: [PATCH] common jar path error, fixed!

---
 streamx-plugin/streamx-flink-sqlcli/pom.xml   | 22 -------------------
 .../flink/submit/trait/FlinkSubmitTrait.scala |  3 ++-
 2 files changed, 2 insertions(+), 23 deletions(-)

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 @@
     <name>StreamX : Flink SQL Cli</name>
 
     <dependencies>
-
-        <dependency>
-            <groupId>org.scala-lang</groupId>
-            <artifactId>scala-library</artifactId>
-            <version>${scala.version}</version>
-            <scope>provided</scope>
-        </dependency>
-
-        <dependency>
-            <groupId>org.scala-lang</groupId>
-            <artifactId>scala-compiler</artifactId>
-            <version>${scala.version}</version>
-            <scope>provided</scope>
-        </dependency>
-
-        <dependency>
-            <groupId>org.scala-lang</groupId>
-            <artifactId>scala-reflect</artifactId>
-            <version>${scala.version}</version>
-            <scope>provided</scope>
-        </dependency>
-
         <dependency>
             <groupId>com.beachape</groupId>
             <artifactId>enumeratum_${scala.binary.version}</artifactId>
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 {