commit e8b4f49cf23c0ee536d0c64736db232c4ce9de60
author wudongliang <46414265+DongLiang-0@users.noreply.github.com> Tue Nov 28 22:50:48 2023 +0800
committer GitHub <noreply@github.com> Tue Nov 28 22:50:48 2023 +0800
tree cc7bf2c494457aa3631cc433a502b8d2da89ddf5
parent 1e2965d17d6e2478183a5dff955a6895c1ec9678

[fix]Fix the first schema change does not take effect when the source table has no data. (#244)

flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java

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 @@
                 }
             }
         } 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));
         }