Hi, I want to update third-party system in the mapFunction ,does mapFunction need to implement CheckpointedFunction?
For example, in the mapFunction I want to update mysql, do I need to implement checkpointfunc, manage the state myself stream=env.addSource() stream.map( "insert update mysql" "A checkpointState to be implemented here?" ) stream.addsink(kafka) good luck!