does mapFunction need to implement CheckpointedFunction?

[liu ze]

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！

[Biao Liu]

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 <[hidden email]> 于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！