You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by sun <13...@qq.com> on 2020/10/27 06:30:10 UTC
请问我把checkpoint恢复到了23号的时间，为什么启动服务后，kafka消息还是从最新的开始消费， 不是应该从23号开始消费吗？
请问我把checkpoint恢复到了23号的时间，为什么启动服务后，kafka消息还是从最新的开始消费， 不是应该从23号开始消费吗？
nohup /opt/flink-1.10.2/bin/flink run -c com.toonyoo.app.data.realcomputation.Application /home/test/ty-app-data-real-computation-1.0.jar -s /opt/flink-1.10.2/checkpoints/f1e8c6bfca15c041c7b3dcf99abfffea/chk-1/_metadata &