File tree Expand file tree Collapse file tree 1 file changed +2
-5
lines changed
core/src/main/java/com/dtstack/flink/sql/parser Expand file tree Collapse file tree 1 file changed +2
-5
lines changed Original file line number Diff line number Diff line change @@ -51,7 +51,7 @@ public static void setLocalSqlPluginRoot(String localSqlPluginRoot){
5151 }
5252
5353 /**
54- * ------ flink 支持的 sql 语法包括--------
54+ * flink support sql syntax
5555 * CREATE TABLE sls_stream() with ();
5656 * CREATE (TABLE|SCALA) FUNCTION fcnName WITH com.dtstack.com;
5757 * insert into tb1 select * from tb2;
@@ -76,12 +76,9 @@ public static SqlTree parseSql(String sql) throws Exception {
7676 SqlTree sqlTree = new SqlTree ();
7777
7878 for (String childSql : sqlArr ){
79-
80-
8179 if (Strings .isNullOrEmpty (childSql )){
8280 continue ;
8381 }
84-
8582 boolean result = false ;
8683 for (IParser sqlParser : sqlParserList ){
8784 if (!sqlParser .verify (childSql )){
@@ -99,7 +96,7 @@ public static SqlTree parseSql(String sql) throws Exception {
9996
10097 //解析exec-sql
10198 if (sqlTree .getExecSqlList ().size () == 0 ){
102- throw new RuntimeException ("sql中没有可执行语句 " );
99+ throw new RuntimeException ("sql no executable statement " );
103100 }
104101
105102 for (InsertSqlParser .SqlParseResult result : sqlTree .getExecSqlList ()){
You can’t perform that action at this time.
0 commit comments