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

diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new 85bfb93  [fix] If there are single quotes in ddl statements, table 
creation fails (#200)
85bfb93 is described below

commit 85bfb93b5fdd0619efaf1da163bd608dbece3b96
Author: Antg <[email protected]>
AuthorDate: Wed Sep 27 18:26:45 2023 +0800

    [fix] If there are single quotes in ddl statements, table creation fails 
(#200)
---
 .../src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java
 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java
index b635a96..77584d3 100644
--- 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java
+++ 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java
@@ -180,7 +180,7 @@ public class DorisSystem {
         //append table comment
         if(!StringUtils.isNullOrWhitespaceOnly(schema.getTableComment())){
             sb.append(" COMMENT '")
-                    .append(schema.getTableComment())
+                    .append(quoteComment(schema.getTableComment()))
                     .append("' ");
         }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to