|
|
With flink 0.10.1 in local I can't connect with jobmanager due the following error:
Association with remote system [akka.tcp://flink@127.0.0.1:49789] has failed, address is now gated for [5000] ms. Reason is: [scala.Option; local class incompatible: stream classdesc serialVersionUID = -2062608324514658839, local class serialVersionUID = -114498752079829388].
And I have all flink 0.10.1 dependencies on my pom.xml
With flink 0.9.1 works fine ... What I'm missing? Thank you!
|
Locked
