godfrey johnson created FLINK-9175:

             Summary: Flink CEP with Checkpointing alway failed
                 Key: FLINK-9175
                 URL: https://issues.apache.org/jira/browse/FLINK-9175
             Project: Flink
          Issue Type: Improvement
          Components: State Backends, Checkpointing
    Affects Versions: 1.4.1
         Environment: Checkpoint Interval: 1min

Checkpoint Timeout: 2min

Checkpoint Pause: 5s

Checkpoint Concurrent: 1

Checkpoint Mode: EXACTLY_ONCE

AllowedLateness: 100s

CEP within time: 30s

Kafka QPS:10,000

Source Parallelism: 16

            Reporter: godfrey johnson
         Attachments: dataStream.png

I used RocksDBStateBackend to checkpoint for my job, and it always failed for 
timeout. But when I closed CEP, only keeped the source operator, which was 
working fine. And FsStateBackend was also finished checkpoint quickly without 




This message was sent by Atlassian JIRA

Reply via email to