(doris-flink-connector) branch master updated: [fix]Fix the first schema change does not take effect when the source table has no data. (#244)

[diwu]

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 e8b4f49  [fix]Fix the first schema change does not take effect when 
the source table has no data. (#244)
e8b4f49 is described below

commit e8b4f49cf23c0ee536d0c64736db232c4ce9de60
Author: wudongliang <46414265+donglian...@users.noreply.github.com>
AuthorDate: Tue Nov 28 22:50:48 2023 +0800

    [fix]Fix the first schema change does not take effect when the source table 
has no data. (#244)
---
 .../flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java      | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java
 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java
index 50ae7fc..37390ce 100644
--- 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java
+++ 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java
@@ -396,6 +396,8 @@ public class JsonDebeziumSchemaSerializer implements 
DorisRecordSerializer<Strin
                 }
             }
         } else {
+            LOG.error("Current schema change failed! You need to ensure that "
+                    + "there is data in the table." + 
dorisOptions.getTableIdentifier());
             originFieldSchemaMap = new LinkedHashMap<>();
             columns.forEach(column -> buildFieldSchema(originFieldSchemaMap, 
column));
         }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org