Re: Questions about managed operator state

Thanks Fabian, After I switched to var it compiles, but its not initialized. @transient private var currentModels : MapState[String, Model] = _ Assignes null to MapState. Do I create an empty hashMap there? Boris Lublinsky FDP Architect boris.lublin...@lightbend.com https://www.lightbend.com/ >

Re: Questions about managed operator state

Hi Boris, the CheckpointedRestoring interface was removed in Flink 1.4.0 (and deprecated in an earlier version). Unfortunately, the docs have not been updated accordingly. I'll open a JIRA to fix this. The replacements for CheckpointedRestoring are the CheckpointedFunction or ListCheckpointed inte

Questions about managed operator state

Documentation https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/stream/state/state.html#using-managed-operator-state Refers to CheckpointedRestoring interface. Whi