fhan688 commented on code in PR #3503:
URL: https://github.com/apache/fluss/pull/3503#discussion_r3448553735
##########
fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/source/split/TieringSplitSerializer.java:
##########
@@ -39,15 +39,15 @@ public class TieringSplitSerializer implements
SimpleVersionedSerializer<Tiering
public static final TieringSplitSerializer INSTANCE = new
TieringSplitSerializer();
- private static final int VERSION_0 = 0;
+ private static final int VERSION_1 = 1;
Review Comment:
> we can avoid bump the version number since the tiering job is statelsss
and the serializer is just for network transmission.
Thanks for the explanation. That makes sense.
Since the tiering source is stateless and this serializer is only used for
split transmission, I’ll avoid bumping the serializer version here and keep it
as version 0 while carrying the new fields in the current
serialization format.
--
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]
