fixed

sunxiaojian · Feb 20, 2024 · 0d8e7dd · 0d8e7dd
1 parent eec10bd
commit 0d8e7dd
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...-cdc/src/main/java/org/apache/paimon/flink/action/cdc/sqlserver/SqlServerActionUtils.java b/...-cdc/src/main/java/org/apache/paimon/flink/action/cdc/sqlserver/SqlServerActionUtils.java
@@ -190,6 +190,7 @@ public static SqlServerSourceBuilder.SqlServerIncrementalSource<String> buildSql
         JsonDebeziumDeserializationSchema debeziumDeserializationSchema =
                 new JsonDebeziumDeserializationSchema(true, converterConfigs);
 
+        sqlServerSourceConfig.setBoolean("debezium.include.schema.changes", false);
         SqlServerSourceBuilder sqlServerSourceBuilder =
                 new SqlServerSourceBuilder()
                         .hostname(sqlServerSourceConfig.get(SqlServerSourceOptions.HOSTNAME))