You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "godfrey johnson (JIRA)" <ji...@apache.org> on 2018/04/16 05:55:00 UTC
[jira] [Updated] (FLINK-9175) Flink CEP with Checkpointing alway
failed
[ https://issues.apache.org/jira/browse/FLINK-9175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
godfrey johnson updated FLINK-9175:
-----------------------------------
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
was:
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
> 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
> Priority: Major
> 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 timeout.
> !dataStream.png!
>
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)