dyp12 commented on code in PR #9701:
URL: https://github.com/apache/seatunnel/pull/9701#discussion_r2278157042
##########
seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/canal/CanalJsonSerializationSchema.java:
##########
@@ -88,9 +98,12 @@ private static SeaTunnelRowType
createJsonRowType(SeaTunnelRowType databaseSchem
// but we don't need them
// and we don't need "old" , because can not support
UPDATE_BEFORE,UPDATE_AFTER
return new SeaTunnelRowType(
- new String[] {"data", "type"},
+ new String[] {"data", "type", "tableId", "ts"},
Review Comment:
> The cancel format is database and table fields, not tableId. Please refer
https://docs.pingcap.com/zh/tidb/stable/ticdc-canal-json/#dml-event
SeaTunnelRow do not have database and table fields， if use tableId to get db
fields，may be get error data，remove it，only add ts field？
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
