flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pwestermann <no.westerm...@genesys.com>
Subject State Processor API: StateMigrationException for keyed state
Date Thu, 12 Dec 2019 18:07:34 GMT
I am trying to get the new State Processor API but I am having trouble with
keyed state (this is for Flink 1.9.1 with RocksDB on S3 as the backend). 
I can read keyed state for simple key type such as Strings but whenever I
tried to read state with a more complex key type - such as a named tuple
type (for example ), I get a StateMigrationException:

Any idea what could be wrong?

Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

View raw message