We support Flink 1.1.2 on the latest snapshot version 0.3.0-incubating-SNAPSHOT. Would it be possible for you to work with this version?
On Tue, Sep 13, 2016 at 11:55 PM, Chawla,Sumit <sumitkcha...@gmail.com> wrote: > When trying to use Beam 0.2.0 with Flink 1.1.0 jar, i am seeing following > error: > > java.lang.NoSuchMethodError: > org.apache.flink.streaming.api.operators.StreamingRuntimeContext.registerTimer(JLorg/apache/flink/streaming/runtime/operators/Triggerable;)V > at > org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper.setNextWatermarkTimer(UnboundedSourceWrapper.java:381) > at > org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper.run(UnboundedSourceWrapper.java:233) > at > org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:80) > at > org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:53) > at > org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:56) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:266) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:584) > at java.lang.Thread.run(Thread.java:745) > > > Regards > Sumit Chawla > > > On Tue, Sep 13, 2016 at 2:20 PM, Chawla,Sumit <sumitkcha...@gmail.com> > wrote: > >> Hi All >> >> The release-0.2.0-incubating supports Flink 1.0.3. With Flink 1.1.0 out, >> is there a plan to support it with any 0.2.0 patch? I tried compiling 0.2.0 >> with Flink 1.1.0, >> and got couple of compliation errors in FlinkGroupAlsoByWindowWrapper.java. >> Going back to master i see lots of change in Flink translation wrappers, >> and >> FlinkGroupAlsoByWindowWrapper.java being removed. >> >> Just want to get a sense of things here, on what would it take to support >> Flink >> 1.1.0 with release-0.2.0. Would appreciate views of people who are already >> working on upgrading it to Flink 1.1.0 >> >> Regards >> Sumit Chawla >> >>
