XiaoHongbo-Hope commented on code in PR #8482:
URL: https://github.com/apache/paimon/pull/8482#discussion_r3530281537
##########
paimon-core/src/main/java/org/apache/paimon/table/source/QueryAuthSplit.java:
##########
@@ -54,10 +61,37 @@ public long rowCount() {
@Override
public OptionalLong mergedRowCount() {
- List<String> filter = authResult.filter();
- if (filter != null && !filter.isEmpty()) {
- return OptionalLong.empty();
+ if (authResult != null) {
+ List<String> filter = authResult.filter();
+ if (filter != null && !filter.isEmpty()) {
+ return OptionalLong.empty();
+ }
}
return split.mergedRowCount();
}
+
+ private void writeObject(ObjectOutputStream out) throws IOException {
+ serialize(new DataOutputViewStreamWrapper(out));
+ }
+
+ private void readObject(ObjectInputStream in) throws IOException,
ClassNotFoundException {
Review Comment:
This breaks Java serialization compatibility for QueryAuthSplit. Old Flink
checkpoints use the previous default object stream, but readObject now expects
the new SplitSerializer format. I reproduced restore as EOFException.
--
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]
