beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Harshal Tripathi (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (BEAM-3919) checkpoint can not work with flink 1.4.1,1.4.2
Date Mon, 26 Mar 2018 08:24:00 GMT

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

Harshal Tripathi commented on BEAM-3919:
----------------------------------------

[~aljoscha], Could you please assign this issue to me?

> checkpoint can not work with flink 1.4.1,1.4.2
> ----------------------------------------------
>
>                 Key: BEAM-3919
>                 URL: https://issues.apache.org/jira/browse/BEAM-3919
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-flink
>    Affects Versions: 2.3.0, 2.4.0
>            Reporter: eisig
>            Priority: Critical
>
> When submmit application to flink cluster(1.4.1,1.4.2) with checkpoint enabled. 
> Job fail whith exception:
> java.lang.NoSuchMethodError: org.apache.flink.streaming.api.operators.HeapInternalTimerService.snapshotTimersForKeyGroup(Lorg/apache/flink/core/memory/DataOutputViewStreamWrapper;I)V
>  
> It seems that `org.apache.flink.streaming.api.operators.HeapInternalTimerService.snapshotTimersForKeyGroup`. 
was changed in flink1.4.1.
>  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message