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 <andrew.ge...@eniro.com> wrote: > 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 classdesc serialVersionUID = -2062608324514658839, local > class serialVersionUID = -114498752079829388]. > > I have doubled checked that my client and server version are the > same(0.10.1), but my java version is a bit different > Java(TM) SE Runtime Environment (build 1.8.0_25-b17) > vs. > Java(TM) SE Runtime Environment (build 1.8.0_60-b27) > > Is java the issue or is there anything else i may be missing? > > > Many thanks > > > Andrew > > > -- > Confidentiality Notice: This e-mail transmission may contain confidential > or legally privileged information that is intended only for the individual > or entity named in the e-mail address. If you are not the intended > recipient, you are hereby notified that any disclosure, copying, > distribution, or reliance upon the contents of this e-mail is strictly > prohibited and may be unlawful. If you have received this e-mail in error, > please notify the sender immediately by return e-mail and delete all copies > of this message.
