[ https://issues.apache.org/jira/browse/FLINK-4300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Timo Walther updated FLINK-4300: -------------------------------- Affects Version/s: 1.1.0 > Improve error message for different Scala versions of JM and Client > ------------------------------------------------------------------- > > Key: FLINK-4300 > URL: https://issues.apache.org/jira/browse/FLINK-4300 > Project: Flink > Issue Type: Improvement > Components: Client, JobManager > Affects Versions: 1.1.0 > Reporter: Timo Walther > > If a user runs a job (e.g. via RemoteEnvironment) with different Scala > versions of JobManager and Client, the job is not executed and has no proper > error message. > The Client fails only with a meaningless warning: > {code} > 16:59:58,677 WARN akka.remote.ReliableDeliverySupervisor > - Association with remote system [akka.tcp://flink@127.0.0.1:6123] has > failed, address is now gated for [5000] ms. Reason is: [Disassociated]. > {code} > JobManager log only contains the following warning: > {code} > 2016-08-01 16:59:58,664 WARN akka.remote.ReliableDeliverySupervisor > - Association with remote system > [akka.tcp://flink@192.168.1.142:63372] has failed, address is now gated for > [5000] ms. Reason is: [scala.Option; local class incompatible: stream > classdesc serialVersionUID = -2062608324514658839, local class > serialVersionUID = -114498752079829388]. > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)