[jira] [Commented] (BEAM-3919) checkpoint can not work with flink 1.4.1,1.4.2
[ https://issues.apache.org/jira/browse/BEAM-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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)
[jira] [Commented] (BEAM-3919) checkpoint can not work with flink 1.4.1,1.4.2
[ https://issues.apache.org/jira/browse/BEAM-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551561#comment-16551561 ] Jozef Vilcek commented on BEAM-3919: I see Beam's master using Flink 1.5.0 in dependencies, so Beam 2.6.0 is most probably what we are waiting for > 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)
[jira] [Commented] (BEAM-3919) checkpoint can not work with flink 1.4.1,1.4.2
[ https://issues.apache.org/jira/browse/BEAM-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551557#comment-16551557 ] Jozef Vilcek commented on BEAM-3919: Unfortunately Beam 2.5.0 is still targeting Flink 1.4.0. Therefore issue is still there. An ETA plan for rolling to Flink 1.5.0 would be much appreciated > 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)
[jira] [Commented] (BEAM-3919) checkpoint can not work with flink 1.4.1,1.4.2
[ https://issues.apache.org/jira/browse/BEAM-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16543690#comment-16543690 ] Joe Malt commented on BEAM-3919: Do you know whether this issue still affects Flink 1.5.0 and Beam 2.5.0? If so, do you have an ETA on fixing it? > 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)
[jira] [Commented] (BEAM-3919) checkpoint can not work with flink 1.4.1,1.4.2
[
https://issues.apache.org/jira/browse/BEAM-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16418549#comment-16418549
]
Harshal Tripathi commented on BEAM-3919:
[~eisig] Yes, you were right,
{code:java}
org.apache.flink.streaming.api.operators.HeapInternalTimerService.snapshotTimersForKeyGroup
{code}
__has been changed (and so have, some others) after 1.4.1 (Including). I have
made the changes, currently, I'm testing the build.
> 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)
[jira] [Commented] (BEAM-3919) checkpoint can not work with flink 1.4.1,1.4.2
[ https://issues.apache.org/jira/browse/BEAM-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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)
