[jira] [Created] (FLINK-4300) Improve error message for different Scala versions of JM and Client

["Timo Walther (JIRA)" <ji...@apache.org>]

Timo Walther created FLINK-4300:
-----------------------------------

             Summary: 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
            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)