[incubator-seatunnel] branch dev updated: [Bugfix][seatunnel-core-flink-sql] fix configuration parsing from sql script (#1825)

[kirs]

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

kirs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 9b113e54 [Bugfix][seatunnel-core-flink-sql] fix configuration parsing 
from sql script (#1825)
9b113e54 is described below

commit 9b113e5484041ae6f3739c6a3165e1c9470ce906
Author: legendtkl <taok...@gmail.com>
AuthorDate: Mon May 9 10:06:42 2022 +0800

    [Bugfix][seatunnel-core-flink-sql] fix configuration parsing from sql 
script (#1825)
---
 config/flink.sql.conf.template                                          | 2 +-
 .../src/main/java/org/apache/seatunnel/core/sql/job/Executor.java       | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/config/flink.sql.conf.template b/config/flink.sql.conf.template
index ddca7e01..4742a04f 100644
--- a/config/flink.sql.conf.template
+++ b/config/flink.sql.conf.template
@@ -21,7 +21,7 @@
 --
 
 
-SET 'table.dml-sync' = 'true';
+SET table.dml-sync = true;
 
 CREATE TABLE events (
   f_type INT,
diff --git 
a/seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/job/Executor.java
 
b/seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/job/Executor.java
index cdcab420..3bd275d3 100644
--- 
a/seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/job/Executor.java
+++ 
b/seatunnel-core/seatunnel-core-flink-sql/src/main/java/org/apache/seatunnel/core/sql/job/Executor.java
@@ -66,7 +66,7 @@ public class Executor {
             Optional<String[]> optional = setOperationParse(stmt);
             if (optional.isPresent()) {
                 String[] setOptionStrs = optional.get();
-                callSetOperation(configuration, setOptionStrs[0], 
setOptionStrs[1]);
+                callSetOperation(configuration, setOptionStrs[0].trim(), 
setOptionStrs[1].trim());
                 continue;
             }
             Operation op = stEnv.getParser().parse(stmt).get(0);