dybyte commented on code in PR #10189:
URL: https://github.com/apache/seatunnel/pull/10189#discussion_r2616327885
##########
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/TableSchema.java:
##########
@@ -92,4 +94,113 @@ public TableSchema copy() {
.primaryKey(primaryKey == null ? null : primaryKey.copy())
.build();
}
+
+ /**
+ * Custom deserialization to handle compatibility with older versions.
+ *
+ * <p>In older versions (before 2.3.12), TableSchema directly contained
columns field. In newer
+ * versions, TableSchema extends AbstractSchema which contains columns
field.
+ *
+ * <p>This method ensures that old checkpoint data can be properly
deserialized by using
+ * ObjectInputStream.GetField to read old version fields and properly
initialize the parent
+ * class fields.
+ */
Review Comment:
The overall changes in `TableSchema` look unrelated to this PR.
--
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]
