dyp12 commented on code in PR #9701:
URL: https://github.com/apache/seatunnel/pull/9701#discussion_r2278374805
##########
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:
> We should update SeaTunnelRowType to CatalogTable in
>
>
https://github.com/apache/seatunnel/blob/9212a77140bb9a310237b4ef82126d42b5d767e6/seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/canal/CanalJsonSerializationSchema.java#L49
>
> Then we can get table and database from CatalogTable.
MetadataUtil.getDatabase use tableId to get db,maybe can use it , update
SeaTunnelRowType to CatalogTable will change manay file
<img width="861" height="362" alt="image"
src="https://github.com/user-attachments/assets/600cdb0c-feb1-430b-9239-4b8409e1270e";
/>
--
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]
