Re: RocksDB MapState debugging key serialization

2021-06-30 Thread Thomas Breloff
FieldSerializer was not producing byte-wise equal serializations. Thanks for the prompt response! Tom From: Yuval Itzchakov Date: Wednesday, June 30, 2021 at 12:56 PM To: Thomas Breloff Cc: user@flink.apache.org Subject: Re: RocksDB MapState debugging key serialization Here is what the

Re: RocksDB MapState debugging key serialization

2021-06-30 Thread Yuval Itzchakov
Here is what the documentation on RocksDBStateBackend says: The EmbeddedRocksDBStateBackend holds in-flight data in a RocksDB database that is (per default) stored in the T

RocksDB MapState debugging key serialization

2021-06-30 Thread Thomas Breloff
Hello, I am having trouble with a Flink job which is configured using a RocksDB state backend. Tl;dr: How can I debug the key serialization for RocksDB MapState for a deployed Flink job? Details: When I “put” a key/value pair into a MapState, and then later try to “get” using a key which has