Re: Link checkpoint failure issue

2018-06-05 Thread Chesnay Schepler
Can you provide us with the TaskManager logs? On 05.06.2018 12:30, James (Jian Wu) [FDS Data Platform] wrote: Hi: I am using Flink streaming continuous query. Scenario: Kafka-connector to consume a topic, and streaming incremental calculate 24 hours window data. And use processingTime a

Link checkpoint failure issue

2018-06-05 Thread James (Jian Wu) [FDS Data Platform]
Hi: I am using Flink streaming continuous query. Scenario: Kafka-connector to consume a topic, and streaming incremental calculate 24 hours window data. And use processingTime as TimeCharacteristic. I am using RocksDB as StateBackend, file system is HDFS, and checkpoint interval is 5 minu