[FLINK-35791][kafka] address comments.

apache · Aug 7, 2024 · 4cd26f8 · 4cd26f8
1 parent 660b632
commit 4cd26f8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonSerializationSchema.java b/.../org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonSerializationSchema.java
@@ -134,7 +134,7 @@ public byte[] serialize(Event event) {
         reuseGenericRowData.setField(
                 3,
                 GenericRowData.of(
-                        StringData.fromString(dataChangeEvent.tableId().getNamespace()),
+                        StringData.fromString(dataChangeEvent.tableId().getSchemaName()),
                         StringData.fromString(dataChangeEvent.tableId().getTableName())));
         try {
             switch (dataChangeEvent.op()) {