[inlong] branch master updated: [INLONG-6968][Sort] Fix the SqlParseException: Encountered "\'" (#6974)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 2f7529146 [INLONG-6968][Sort] Fix the SqlParseException: Encountered 
"\'" (#6974)
2f7529146 is described below

commit 2f75291467b9f1045e56ff15806fd0231284b812
Author: wangpeix <105137931+wangp...@users.noreply.github.com>
AuthorDate: Wed Dec 21 10:33:47 2022 +0800

    [INLONG-6968][Sort] Fix the SqlParseException: Encountered "\'" (#6974)
    
    Co-authored-by: wangpeix <luckywang...@didiglobal.com>
---
 .../java/org/apache/inlong/sort/parser/impl/NativeFlinkSqlParser.java   | 2 +-
 .../java/org/apache/inlong/sort/parser/NativeFlinkSqlParserTest.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/parser/impl/NativeFlinkSqlParser.java
 
b/inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/parser/impl/NativeFlinkSqlParser.java
index dbbaa069a..3227c2ad1 100644
--- 
a/inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/parser/impl/NativeFlinkSqlParser.java
+++ 
b/inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/parser/impl/NativeFlinkSqlParser.java
@@ -82,7 +82,7 @@ public class NativeFlinkSqlParser implements Parser {
         Preconditions.checkNotNull(tableEnv, "tableEnv is null");
         List<String> createTableSqls = new ArrayList<>();
         List<String> insertSqls = new ArrayList<>();
-        String[] statementSet = statements.split(";");
+        String[] statementSet = statements.split(";(\\r?\\n|\\r)");
         for (String statement : statementSet) {
             statement = statement.trim();
             if (statement.toUpperCase(Locale.ROOT).startsWith("CREATE TABLE") 
|| statement.toUpperCase(Locale.ROOT)
diff --git 
a/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/NativeFlinkSqlParserTest.java
 
b/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/NativeFlinkSqlParserTest.java
index 07f65d21b..a8f60f0be 100644
--- 
a/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/NativeFlinkSqlParserTest.java
+++ 
b/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/NativeFlinkSqlParserTest.java
@@ -71,7 +71,7 @@ public class NativeFlinkSqlParserTest {
                 + "    SELECT \n"
                 + "    `name` AS `name`,\n"
                 + "    `age` AS `age`\n"
-                + "    FROM `table_1`;";
+                + "    FROM `table_1`;\n";
         NativeFlinkSqlParser parser = 
NativeFlinkSqlParser.getInstance(tableEnv, data);
         ParseResult result = parser.parse();
         Assert.assertTrue(result.tryExecute());