[FLINK-9175] Flink CEP with Checkpointing alway failed

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.4.1
• Component/s: Library / CEP, Runtime / Checkpointing
• Labels: auto-deprioritized-critical auto-deprioritized-major auto-deprioritized-minor

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

 

• Assignee: Unassigned
• Reporter: Godfrey He
• Created: 15/Apr/18 03:52
• Updated: 30/Dec/21 22:38

Description

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