You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ki...@apache.org on 2022/05/09 02:06:46 UTC
[incubator-seatunnel] branch dev updated: [Bugfix][seatunnel-core-flink-sql] fix configuration parsing from sql script (#1825)
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 <ta...@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);