Hi Robert,
Thank you for the prompt reply. You're right, it was a left over from a
previous build. With the fixed dependencies, I get the same error though.
A have a question on job submission as well. I use the following code to
submit the job:
InetSocketAddress jobManagerAddress = cluster
Hi Theo,
you can't mix different Flink versions in your dependencies. Please use
1.0.2 for the flink_yarn client as well or 1.1-SNAPSHOT everywhere.
On Fri, May 6, 2016 at 7:02 PM, Theofilos Kakantousis wrote:
> Hi everyone,
> Flink 1.0.2
> Hadoop 2.4.0
>
> I am running Flink on Yarn by using F
