[ https://issues.apache.org/jira/browse/FLINK-8917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chesnay Schepler closed FLINK-8917. ----------------------------------- Resolution: Won't Fix Fix Version/s: (was: 1.4.3) The affected classes will be removed soon in FLINK-10540. > FlinkMiniCluster default createHighAvailabilityServices is not same as > ClusterClient > ------------------------------------------------------------------------------------ > > Key: FLINK-8917 > URL: https://issues.apache.org/jira/browse/FLINK-8917 > Project: Flink > Issue Type: Bug > Components: Job-Submission > Affects Versions: 1.4.0 > Reporter: jianran.tfh > Priority: Minor > > FlinkMiniCluster default createHighAvailabilityServices is not same as > ClusterClient, > the FlinkMiniCluster used > HighAvailabilityServicesUtils.createAvailableOrEmbeddedServices > but the ClusterClient used > HighAvailabilityServicesUtils.createHighAvailabilityServices,so if you use > the flink-1.4 in zeppelin,the job submission will be failed with the follow > msg: > Discard message > LeaderSessionMessage(00000000-0000-0000-0000-000000000000,SubmitJob(JobGraph(jobId: > 33d8e7d74aa48f76a1622d4d8f78105e),EXECUTION_RESULT_AND_STATE_CHANGES)) > because the expected leader session ID 87efb7ca-b761-4977-9696-d521bc178703 > did not equal the received leader session ID > 00000000-0000-0000-0000-000000000000. -- This message was sent by Atlassian JIRA (v7.6.3#76005)