[fix] fix LocalTest判断问题以及删除无用import

Author: FlechazoW

.gitignore

@@ -14,5 +14,4 @@ lib/
 .DS_Store
 bin/nohup.out
 .DS_Store
-bin/sideSql.txt
-localTest/
+bin/sideSql.txt

core/src/main/java/com/dtstack/flink/sql/side/SideSqlExec.java

@@ -20,24 +20,8 @@
 
 package com.dtstack.flink.sql.side;
 
-import com.dtstack.flink.sql.enums.EPluginLoadMode;
-import org.apache.flink.api.common.typeinfo.TypeInformation;
-import org.apache.flink.api.common.typeinfo.Types;
-import org.apache.flink.api.java.tuple.Tuple2;
-import org.apache.flink.api.java.typeutils.RowTypeInfo;
-import org.apache.flink.api.java.typeutils.TupleTypeInfo;
-import org.apache.flink.streaming.api.datastream.DataStream;
-import org.apache.flink.table.api.EnvironmentSettings;
-import org.apache.flink.table.api.Table;
-import org.apache.flink.table.api.TableSchema;
-import org.apache.flink.table.api.java.StreamTableEnvironment;
-import org.apache.flink.table.api.java.internal.StreamTableEnvironmentImpl;
-import org.apache.flink.table.catalog.CatalogManager;
-import org.apache.flink.table.catalog.ObjectIdentifier;
-import org.apache.flink.table.typeutils.TimeIndicatorTypeInfo;
-import org.apache.flink.types.Row;
-
 import com.dtstack.flink.sql.enums.ECacheType;
+import com.dtstack.flink.sql.enums.EPluginLoadMode;
 import com.dtstack.flink.sql.exec.FlinkSQLExec;
 import com.dtstack.flink.sql.parser.CreateTmpTableParser;
 import com.dtstack.flink.sql.side.operator.SideAsyncOperator;
@@ -55,18 +39,15 @@
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.flink.api.common.typeinfo.TypeInformation;
-import org.apache.flink.api.common.typeinfo.Types;
-import org.apache.flink.api.java.tuple.Tuple2;
 import org.apache.flink.api.java.typeutils.RowTypeInfo;
-import org.apache.flink.api.java.typeutils.TupleTypeInfo;
 import org.apache.flink.streaming.api.datastream.DataStream;
 import org.apache.flink.table.api.EnvironmentSettings;
 import org.apache.flink.table.api.Table;
 import org.apache.flink.table.api.TableSchema;
 import org.apache.flink.table.api.java.StreamTableEnvironment;
+import org.apache.flink.table.catalog.ObjectIdentifier;
 import org.apache.flink.table.runtime.typeutils.BaseRowTypeInfo;
 import org.apache.flink.table.types.logical.LogicalType;
-import org.apache.flink.table.catalog.ObjectIdentifier;
 import org.apache.flink.table.typeutils.TimeIndicatorTypeInfo;
 import org.apache.flink.types.Row;
 import org.slf4j.Logger;
@@ -105,7 +86,7 @@ public void exec(String sql,
                      Map<String, Table> tableCache,
                      CreateTmpTableParser.SqlParserResult createView,
                      String scope) throws Exception {
-        if (localSqlPluginPath == null && !pluginLoadMode.equals(EPluginLoadMode.LOCALTEST.name())) {
+        if (!pluginLoadMode.equalsIgnoreCase(EPluginLoadMode.LOCALTEST.name()) && localSqlPluginPath == null ) {
             throw new RuntimeException("need to set localSqlPluginPath");
         }
 

localTest/src/main/java/com/dtstack/flink/sql/localTest/LocalTest.java

@@ -50,7 +50,7 @@ public static void main(String[] args) throws Exception {
         setLogLevel("INFO");
 
         List<String> propertiesList = new ArrayList<>();
-        String sqlPath = "/Users/xuchao/Documents/flinkSql/share/twodimjoin.sql";
+        String sqlPath = "/Users/wtz4680/Desktop/flinkStreamSQL/sql/rowtimeprint.sql";
         Map<String, Object> conf = new HashMap<>();
         JSONObject properties = new JSONObject();