????????~



------------------ ???????? ------------------
??????: "shengjk1"<jsjsjs1...@163.com>;
????????: 2019??3??27??(??????) ????12:10
??????: "user-zh@flink.apache.org"<user-zh@flink.apache.org>;
????: "user-zh"<user-zh@flink.apache.org>; 
????: ??????  flink savepoints ?? checkpoints??????



 ??????flink-connector-kafka????kafka 
0.8????????????????????????zk????????????????????kafka??(??????kafka??????API)


????Flink????????????????????offset????????????????????checkpoint??
??????????checkpoint????????kafka??????API????offset??????
??????????checkpoint??flink????????checkpoint????????offset????????????state 
backends??????????????kafka consumer??????Api??????kafka
????????????
https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/connectors/kafka.html


Best,
Shengjk1




??2019??03??27?? 11:52??????<1048095...@qq.com> ??????
??????????????????checkpoint??savepoint????????????????????????????????????????????????????????????????????????????????????
????????????????????
1??flink ???? 
kafka??kafka??offset????flink??????????????????????????????????zookeeper????
PS??????zookeeper??????????offset????????????????????????????????
2????????????????????????????????????????????????????flink??????????????offset????????????zookeeper??




------------------ ???????? ------------------
??????: "baiyg25...@hundsun.com"<baiyg25...@hundsun.com>;
????????: 2019??3??27??(??????) ????11:38
??????: "user-zh"<user-zh@flink.apache.org>;

????: ????: ?????? flink savepoints ?? checkpoints??????






???????????????????? savepoint 
??????????????????????????????????????????????????savepoints????????????????????????????????????????????????????????????????????????????????????????????





baiyg25...@hundsun.com



???????? ????
?????????? 2019-03-27 11:03
???????? user-zh
?????? ?????? flink savepoints ?? checkpoints??????


??????savepoint????????????????????????????????????????????????????????????savepoints????




------------------ ???????? ------------------
??????: "baiyg25...@hundsun.com"<baiyg25...@hundsun.com>;
????????: 2019??3??27??(??????) ????11:01
??????: "user-zh"<user-zh@flink.apache.org>;

????: ????: flink savepoints ?? checkpoints??????



checkpoints:
????????????????????????????????????????????checkpoint??????????????????????????????????????????????????????????????????????????????

savepoints??
????????????????????????????????????????????????????????????savepoints????????????????????????????????????????savepoints????????????????????????????????????????????????????savepoints????????????????????????????????????savepoints????????????????





baiyg25...@hundsun.com

???????? ????
?????????? 2019-03-27 10:48
???????? user-zh
?????? flink savepoints ?? checkpoints??????
??????????flink savepoints ?? 
checkpoints????????????????????checkpoints??????????????????savepoints????????????????????????????????????????????????????savepoints??????????????savepoints??
PS??????????????checkpoints, 
3s??????????cancel??????????????????-s??????savepoints????????????????????????????savepoints????????????checkpoints????????????????????????????

回复