Sorry, I don't get your point. Before answering the question, I guess we need to make sure what you exactly want.
BTW, have you read the document of checkpointing or state? [1] [2] Maybe it could help. 1. https://ci.apache.org/projects/flink/flink-docs-release-1.8/concepts/programming-model.html#checkpoints-for-fault-tolerance 2. https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/stream/state/ liu ze <liuze0...@gmail.com> 于2019年7月5日周五 下午2:37写道： > 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！
