[ https://issues.apache.org/jira/browse/BEAM-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16588744#comment-16588744 ]
Aljoscha Krettek commented on BEAM-3919: ---------------------------------------- Unfortunately, I don't think we can fix this right now with the incompatible changes in minor Flink versions. > 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 > Assignee: Harshal Tripathi > 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)