Hi Max
I was able to compile 0.2.0 with Flink 1.1.0 with small modification, and
run a simple pipeline.
@Override
- public void restoreState(StreamTaskState taskState, long
recoveryTimestamp) throws Exception {
- super.restoreState(taskState, recoveryTimestamp);
+ public void restoreState(StreamTaskState taskState) throws Exception {
+ super.restoreState(taskState);
Can i get a sense of the changes that have happened in 0.3.0 for Flink? I
observed some classes completely reworked. It will be crucial for me to
understand the scope of change and impact before making a move to 0.3.0
Regards
Sumit Chawla
On Wed, Sep 14, 2016 at 3:03 AM, Maximilian Michels <[email protected]> wrote:
> 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 <[email protected]>
> 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 <[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
> >>
> >>
>
