Hi all, I'm experimenting with checkpoints/savepoints in Beam (version 2.14) when using a Flink (version 1.6.4) runner. Flink was able to take periodic checkpoints when I setup the flink-conf.yaml correctly. But I was thinking if it's possible to set the StateBackend on a per job level by flagging the --state_backend=RocksDBStateBackend option since it's said to be supported here <https://beam.apache.org/documentation/runners/flink/>.
But instead I got the following error: RuntimeError: Pipeline failed in state FAILED: com.fasterxml.jackson.databind.exc.InvalidDefinitionException: Cannot construct instance of `org.apache.flink.runtime.state.StateBackend` (no Creators, like default construct, exist): abstract types either need to be mapped to concrete types, have custom deserializer, or contain additional type information at [Source: (String)""RocksDBStateBackend""; line: 1, column: 1] I then saw that there's: @JasonIgnore StateBackend getStateBackend(); I'm wondering if this is not supported in python yet? If yes then do we have plans to support this in the near future? Best, Catlyn
