flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Sihua Zhou (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-9175) Flink CEP with Checkpointing alway failed
Date Mon, 23 Apr 2018 04:47:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-9175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447562#comment-16447562
] 

Sihua Zhou commented on FLINK-9175:
-----------------------------------

Hi [~godfrey] Is it possible to provide your sample code that could reproduce this? I think
that could be helpful.

> 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: checkpoint failed.png, 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)

Mime
View raw message