??????flink ??????????

Sun, 21 Jun 2020 19:58:49 -0700 

Hi


??????????????INFO??????????????????job????????checkpoint????


Best,
Yichao Yang




------------------ ???????? ------------------
??????:&nbsp;"Tony"<[email protected]&gt;;
????????:&nbsp;2020??6??22??(??????) ????10:54
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;flink ??????????



??????


????????????????????flink??????????flink-conf.yaml????????
high-availability:zookeeper
high-availability.zookeeper.quorum:master:2181 ,slave1:2181,slave2:2181
high-availability.zookeeper.path.root:/flink 
high-availability.cluster-id:/cluster_one 
highavailability.storageDir:hdfs://master:9000/flink/ha


????flink??zookeeper??????K8s????????
job????????????????????????????????????????
2020-06-22 02:47:43,884 INFO&nbsp; 
org.apache.flink.runtime.checkpoint.CheckpointCoordinator&nbsp;&nbsp;&nbsp;&nbsp;
 - Checkpoint triggering task Source:Kafka-Consumer -&gt; (Sink: Print to Std. 
Out, Filter -&gt;Query Map -&gt; Unwind -&gt; Custom Map -&gt; filter -&gt; 
Data Transformation -&gt; Filter) (1/1) of job 00000000000000000000000000000000 
is not in state RUNNING but SCHEDULED instead. Aborting checkpoint.

回复