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

2019-03-27 文章 shengjk1



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??????

2019-03-26 文章 ????
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??????

2019-03-26 文章 ????
~




--  --
??: "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??????

2019-03-26 文章 shengjk1
 ??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??????

2019-03-26 文章 ????
??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??????

2019-03-26 文章 ????
??




--  --
??: "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??????

2019-03-26 文章 baiyg25...@hundsun.com

 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??????

2019-03-26 文章 ????
??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??????

2019-03-26 文章 baiyg25...@hundsun.com
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??????

2019-03-26 文章 ????
??flink savepoints ?? 
checkpointscheckpoints??savepointssavepoints??savepoints??
PS??checkpoints, 
3s??cancel??-s??savepointssavepointscheckpoints