?????? flink savepoints ?? checkpoints??????
flink??flink??kafka??kafka??flink??kafkaconsumer ??kafkaproducer??flink??kafka offset??group.id??group.idkafka??api flink??applicationgroup?? ??flinkkafka consumer??APi assign() kafka subscribe() ??group.id kafka consumer ?? Best, Shengjk1 ??2019??03??27?? 14:24??<1048095...@qq.com<1048095...@qq.com>> ?? checkpoint??flink??kafka offsetflink?? PSkafkfa sourcegroup.id??flink??applicationgroup -- -- ??: ""<1048095...@qq.com>; : 2019??3??27??(??) 1:42 ??: "user-zh"; : ?? flink savepoints ?? checkpoints?? ~ -- -- ??: "shengjk1"; : 2019??3??27??(??) 12:10 ??: "user-zh@flink.apache.org"; : "user-zh"; : ?? flink savepoints ?? checkpoints?? ??flink-connector-kafkakafka 0.8zkkafka??(??kafka??API) Flinkoffsetcheckpoint?? ??checkpointkafka??APIoffset?? ??checkpoint??flinkcheckpointoffsetstate 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??offsetflink??zookeeper PS??zookeeper??offset 2flink??offsetzookeeper?? -- -- ??: "baiyg25...@hundsun.com"; ????: 2019??3??27??(??) 11:38 ??: "user-zh"; : : ?? flink savepoints ?? checkpoints?? savepoint ??savepoints baiyg25...@hundsun.com ???? ?? 2019-03-27 11:03 user-zh ?? ?? flink savepoints ?? checkpoints?? ??savepointsavepoints -- -- ??: "baiyg25...@hundsun.com"; ????: 2019??3??27??(??) 11:01 ??: "user-zh"; : : flink savepoints ?? checkpoints?? checkpoints: checkpoint?? savepoints?? savepointssavepointssavepointssavepoints???????? baiyg25...@hundsun.com ???? ?????? 2019-03-27 10:48 user-zh ?? flink savepoints ?? checkpoints?? ??flink savepoints ?? checkpointscheckpoints??savepointssavepoints??savepoints?? PS??checkpoints, 3s??cancel??-s??savepointssavepointscheckpoints
?????? flink savepoints ?? checkpoints??????
checkpoint??flink??kafka offsetflink?? PSkafkfa sourcegroup.id??flink??applicationgroup -- -- ??: ""<1048095...@qq.com>; : 2019??3??27??(??) 1:42 ??: "user-zh"; : ?? flink savepoints ?? checkpoints?? ~ -- -- ??: "shengjk1"; : 2019??3??27??(??) 12:10 ??: "user-zh@flink.apache.org"; ????: "user-zh"; : ?? flink savepoints ?? checkpoints?? ??flink-connector-kafkakafka 0.8zkkafka??(??kafka??API) Flinkoffsetcheckpoint?? ??checkpointkafka??APIoffset?? ??checkpoint??flinkcheckpointoffsetstate 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??offsetflink??zookeeper PS??zookeeper??offset 2flink??offsetzookeeper?? -- -- ??: "baiyg25...@hundsun.com"; : 2019??3??27??(??) 11:38 ??: "user-zh"; : : ?? flink savepoints ?? checkpoints?? savepoint ??savepoints baiyg25...@hundsun.com ???? ???? ?? 2019-03-27 11:03 user-zh ?? ?? flink savepoints ?? checkpoints?? ??savepointsavepoints -- -- ??: "baiyg25...@hundsun.com"; ????: 2019??3??27??(??) 11:01 ??: "user-zh"; : : flink savepoints ?? checkpoints?? checkpoints: checkpoint?? savepoints?? savepointssavepointssavepointssavepoints???? baiyg25...@hundsun.com ???? ?????? 2019-03-27 10:48 ???? user-zh ?? flink savepoints ?? checkpoints?? ??flink savepoints ?? checkpointscheckpoints??savepointssavepoints??savepoints?? PS??checkpoints, 3s??cancel??-s??savepointssavepointscheckpoints
?????? flink savepoints ?? checkpoints??????
~ -- -- ??: "shengjk1"; : 2019??3??27??(??) 12:10 ??: "user-zh@flink.apache.org"; : "user-zh"; : ?? flink savepoints ?? checkpoints?? ??flink-connector-kafkakafka 0.8zkkafka??(??kafka??API) Flinkoffsetcheckpoint?? ??checkpointkafka??APIoffset?? ??checkpoint??flinkcheckpointoffsetstate 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??offsetflink??zookeeper PS??zookeeper??offset 2flink??offsetzookeeper?? -- -- ??: "baiyg25...@hundsun.com"; : 2019??3??27??(??) ????11:38 ??: "user-zh"; : : ?? flink savepoints ?? checkpoints?? savepoint ??savepoints baiyg25...@hundsun.com ?????? 2019-03-27 11:03 ???? user-zh ?? ?? flink savepoints ?? checkpoints?? ??savepointsavepoints -- -- ??: "baiyg25...@hundsun.com"; : 2019??3??27??(??) 11:01 ??: "user-zh"; : : flink savepoints ?? checkpoints?? checkpoints: checkpoint?? savepoints?? savepointssavepointssavepointssavepoints baiyg25...@hundsun.com ???? ???? ?????? 2019-03-27 10:48 ???? user-zh ?? flink savepoints ?? checkpoints?? ??flink savepoints ?? checkpointscheckpoints??savepointssavepoints??savepoints?? PS??checkpoints, 3s??cancel??-s??savepointssavepointscheckpoints
?????? flink savepoints ?? checkpoints??????
??flink-connector-kafkakafka 0.8zkkafka??(??kafka??API) Flinkoffsetcheckpoint?? ??checkpointkafka??APIoffset?? ??checkpoint??flinkcheckpointoffsetstate 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??offsetflink??zookeeper PS??zookeeper??offset 2flink??offsetzookeeper?? -- -- ??: "baiyg25...@hundsun.com"; : 2019??3??27??(??) 11:38 ??: "user-zh"; : ????: ?? flink savepoints ?? checkpoints?? savepoint ??savepoints baiyg25...@hundsun.com ?? 2019-03-27 11:03 ???? user-zh ?? ?? flink savepoints ?? checkpoints?? ??savepointsavepoints -- -- ??: "baiyg25...@hundsun.com"; : 2019??3??27??(??) 11:01 ??: "user-zh"; : : flink savepoints ?? checkpoints?? checkpoints: checkpoint?? savepoints?? savepointssavepointssavepointssavepoints baiyg25...@hundsun.com ?? 2019-03-27 10:48 user-zh ?? flink savepoints ?? checkpoints?????? ??flink savepoints ?? checkpointscheckpoints??savepointssavepoints??savepoints?? PS??checkpoints, 3s??cancel??-s??savepointssavepointscheckpoints
?????? ?????? flink savepoints ?? checkpoints??????
??checkpoint??savepoint 1??flink kafka??kafka??offsetflink??zookeeper PS??zookeeper??offset 2flink??offsetzookeeper?? -- -- ??: "baiyg25...@hundsun.com"; : 2019??3??27??(??) 11:38 ??: "user-zh"; : : ?????? flink savepoints ?? checkpoints?? savepoint ??savepoints baiyg25...@hundsun.com ?? 2019-03-27 11:03 user-zh ?? ?????? flink savepoints ?? checkpoints?? ??savepointsavepoints -- -- ??: "baiyg25...@hundsun.com"; : 2019??3??27??(??) 11:01 ??: "user-zh"; ????: : flink savepoints ?? checkpoints?? checkpoints: checkpoint?? savepoints?? savepointssavepointssavepointssavepoints baiyg25...@hundsun.com ?? 2019-03-27 10:48 ???? user-zh ?? flink savepoints ?? checkpoints?? ??flink savepoints ?? checkpointscheckpoints??savepointssavepoints??savepoints?? PS??checkpoints, 3s??cancel??-s??savepointssavepointscheckpoints
?????? ?????? flink savepoints ?? checkpoints??????
?? -- -- ??: "baiyg25...@hundsun.com"; : 2019??3??27??(??) 11:38 ??: "user-zh"; : : ?????? flink savepoints ?? checkpoints?? savepoint ??savepoints baiyg25...@hundsun.com ?? 2019-03-27 11:03 user-zh ?? ?????? flink savepoints ?? checkpoints?? ??savepointsavepoints -- -- ??: "baiyg25...@hundsun.com"; : 2019??3??27??(??) 11:01 ??: "user-zh"; ????: : flink savepoints ?? checkpoints?? checkpoints: checkpoint?? savepoints?? savepointssavepointssavepointssavepoints baiyg25...@hundsun.com ?? 2019-03-27 10:48 ???? user-zh ?? flink savepoints ?? checkpoints?? ??flink savepoints ?? checkpointscheckpoints??savepointssavepoints??savepoints?? PS??checkpoints, 3s??cancel??-s??savepointssavepointscheckpoints
????: ?????? flink savepoints ?? checkpoints??????
savepoint ??savepoints baiyg25...@hundsun.com ?? 2019-03-27 11:03 user-zh ?? ?? flink savepoints ?? checkpoints?? ??savepointsavepoints -- -- ??: "baiyg25...@hundsun.com"; : 2019??3??27??(??) 11:01 ??: "user-zh"; : ????: flink savepoints ?? checkpoints?? checkpoints: checkpoint?? savepoints?? savepointssavepointssavepointssavepoints baiyg25...@hundsun.com ?? 2019-03-27 10:48 user-zh ?????? flink savepoints ?? checkpoints?????? ??flink savepoints ?? checkpointscheckpoints??savepointssavepoints??savepoints?? PS??checkpoints, 3s??cancel??-s??savepointssavepointscheckpoints
?????? flink savepoints ?? checkpoints??????
??savepointsavepoints -- -- ??: "baiyg25...@hundsun.com"; : 2019??3??27??(??) 11:01 ??: "user-zh"; : ????: flink savepoints ?? checkpoints?? checkpoints: checkpoint?? savepoints?? savepointssavepointssavepointssavepoints baiyg25...@hundsun.com ?? 2019-03-27 10:48 user-zh ?????? flink savepoints ?? checkpoints?????? ??flink savepoints ?? checkpointscheckpoints??savepointssavepoints??savepoints?? PS??checkpoints, 3s??cancel??-s??savepointssavepointscheckpoints
????: flink savepoints ?? checkpoints??????
checkpoints: checkpoint?? savepoints?? savepointssavepointssavepointssavepoints baiyg25...@hundsun.com ?? 2019-03-27 10:48 user-zh ?? flink savepoints ?? checkpoints?? ??flink savepoints ?? checkpointscheckpoints??savepointssavepoints??savepoints?? PS??checkpoints, 3s??cancel??-s??savepointssavepointscheckpoints
flink savepoints ?? checkpoints??????
??flink savepoints ?? checkpointscheckpoints??savepointssavepoints??savepoints?? PS??checkpoints, 3s??cancel??-s??savepointssavepointscheckpoints
