Thanks…I was rebuilt the connector. It seems like the jar I was using was not
built correctly at the first time. Yes it solved the issue.
From: "Tzu-Li (Gordon) Tai"
Date: Tuesday, May 23, 2017 at 11:30 PM
To: "user@flink.apache.org"
Subject: Re: flink 1.2 job fails wh
Hi Sathi,
You seem to have built the Kinesis connector on Flink 1.3, but using it against
Flink 1.2. Please make sure that the library versions and the Flink version
match.
As for the case you’ve bumped in to: it just happens that with parallelism 1,
the `markAsTemporarilyIdle` method is not c
Need quick help on this
Trying to run
/bin/flink run -p 6 –c CLASSNAME - /mnt/flink/jarname.jar
everything works without –p option ,but runs with parallelization 1, which is
what I am trying to get past.
java.lang.NoSuchMethodError:
org.apache.flink.streaming.api.functions.source.SourceFunctio
