Hi all, If I implement ListCheckpointed in a function, is there a guarantee that open() is called before restoreState()?
Asking because it doesn’t seem to be the case, and I didn’t notice this being described here: https://ci.apache.org/projects/flink/flink-docs-release-1.4/internals/task_lifecycle.html <https://ci.apache.org/projects/flink/flink-docs-release-1.4/internals/task_lifecycle.html> If so, then is it normally best practice to also implement the CheckpointedFunction interface, so that initializeState() method is called before the restore? In Flink test code, I don’t see this typically being done. Thanks, — Ken -------------------------- Ken Krugler http://www.scaleunlimited.com custom big data solutions & training Hadoop, Cascading, Cassandra & Solr
