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