JingsongLi commented on code in PR #8482:
URL: https://github.com/apache/paimon/pull/8482#discussion_r3532880948
##########
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 is expected. Firstly, cross version compatibility is not guaranteed,
and secondly, QueryAuthSplit is generally not saved in Flink state.
However, I should indeed increase the serial Version UID to make the
exception more apparent.
--
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]
