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!

Reply via email to