You're welcome. As of recent changes, all Maven artifact names are now
suffixed with the Scala major version. However, the old artifacts are
still available for the snapshot version. I've just pushed an empty
flink-streaming-java for 1.0-SNAPSHOT to prevent users from compiling
code which would fai
Yes, found a special dependency for 2.11, Thanks!
org.apache.flink
flink-streaming-java_2.11
${apache.flink.versin}
Andrew
> On 08 Feb 2016, at 14:18, Andrew Ge Wu wrote:
>
> Thanks Max
>
> My local and remote environment are running: Scala code runner versi
Thanks Max
My local and remote environment are running: Scala code runner version 2.11.7
-- Copyright 2002-2013, LAMP/EPFL
And I downloaded binary
2.11(//apache.mirrors.spacedump.net/flink/flink-0.10.1/flink-0.10.1-bin-hadoop27-scala_2.11.tgz),
Is there a different version of client lib for scal
Hi Andrew,
It appears that you're using two different versions of the Scala
library in your Flink job. Please make sure you use either 2.10 or
2.11 but not both at the same time.
Best,
Max
On Mon, Feb 8, 2016 at 10:30 AM, Andrew Ge Wu wrote:
> Hi All
>
> I’m new to flink and come to the step to
Hi All
I’m new to flink and come to the step to submit to a remote cluster, and it
failed with following message:
Association with remote system [akka.tcp://flink@127.0.0.1:61231] has failed,
address is now gated for [5000] ms. Reason is: [scala.Option; local class
incompatible: stream classde
