假如一个类比如: FlinkKafkaConsumerBase 继承了 RichParallelSourceFunction 和CheckpointedFunction，并且重写了RichParallelSourceFunction 的open方法和CheckpointedFunction initializeState方法，那么是先执行open呢还是initializeState呢？这个怎么判断的呀/-问答-阿里云开发者社区-阿里云

假如一个类比如: FlinkKafkaConsumerBase 继承了 RichParallelSourceFunction 和CheckpointedFunction，并且重写了RichParallelSourceFunction 的open方法和CheckpointedFunction initializeState方法，那么是先执行open呢还是initializeState呢？这个怎么判断的呀/

flink小助手

2019-01-10 16:36:49

3474

假如一个类比如: FlinkKafkaConsumerBase 继承了 RichParallelSourceFunction
和CheckpointedFunction，并且重写了RichParallelSourceFunction 的open方法和CheckpointedFunction initializeState方法，那么是先执行open呢还是initializeState呢？这个怎么判断的呀/

取消提交回答

全部回答(1)

flink小助手
2019-07-17 23:25:11

先调用 initializeState
社区不建议使用这个类了，已经 deprecated 了，如果你用 ListCheckpointed 的话，注释里写的比较清楚

0 0

云计算

使用钉钉扫一扫加入圈子

+ 订阅

时时分享云计算技术内容，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。