update

JNSimba · Nov 29, 2023 · f66902a · f66902a
1 parent 3868071
commit f66902a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java b/...main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java
@@ -171,7 +171,7 @@ public DorisRecord serialize(String record) throws IOException {
                 addDeleteSign(valueMap, false);
                 break;
             case OP_UPDATE:
-                return DorisRecord.of(extractUpdate(recordRoot));
+                return DorisRecord.of(dorisTableIdentifier, extractUpdate(recordRoot));
             case OP_DELETE:
                 valueMap = extractBeforeRow(recordRoot);
                 addDeleteSign(valueMap, true);