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 <[email protected]>
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
>
>
