Merge pull request #5 from DTStack/v1.4.0

V1.4.0

Author: yangsishu

README.md

@@ -37,8 +37,6 @@
 
 ```
 mvn clean package -Dmaven.test.skip
-
-所有插件包会生成到plugins下
 ```
 
 打包结束后，项目根目录下会产生plugins目录，plugins目录下存放编译好的数据同步插件包

core/src/main/java/com/dtstack/flink/sql/parser/SqlParser.java

@@ -51,7 +51,7 @@ public static void setLocalSqlPluginRoot(String localSqlPluginRoot){
     }
 
     /**
-     * ------flink 支持的 sql 语法包括--------
+     * flink support sql syntax
      * CREATE TABLE sls_stream() with ();
      * CREATE (TABLE|SCALA) FUNCTION fcnName WITH com.dtstack.com;
      * insert into tb1 select * from tb2;
@@ -76,12 +76,9 @@ public static SqlTree parseSql(String sql) throws Exception {
         SqlTree sqlTree = new SqlTree();
 
         for(String childSql : sqlArr){
-
-
             if(Strings.isNullOrEmpty(childSql)){
                 continue;
             }
-
             boolean result = false;
             for(IParser sqlParser : sqlParserList){
                 if(!sqlParser.verify(childSql)){
@@ -99,7 +96,7 @@ public static SqlTree parseSql(String sql) throws Exception {
 
         //解析exec-sql
         if(sqlTree.getExecSqlList().size() == 0){
-            throw new RuntimeException("sql中没有可执行语句");
+            throw new RuntimeException("sql no executable statement");
         }
 
         for(InsertSqlParser.SqlParseResult result : sqlTree.getExecSqlList()){