Hi Mahesh,
Thanks a lot for reporting this. This would be a bug:
https://issues.apache.org/jira/browse/FLINK-6844.
Apparently the TraversableSerializer could take part in checkpointing and
therefore should implement the new compatibility methods.
I’ll make sure that the fix for this gets into 1
Dear all,
My Flink Job reads from a kafka topic and store the data in a RocksDB state
backend, in order to make use of the queryable state. I'm able to run the
job and query the state in my local machine. But when deploying on the
cluster, I'm getting the below error:
Caused by: org.apache.flink.
