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/
