[ 
https://issues.apache.org/jira/browse/FLINK-15434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011503#comment-17011503
 ] 

hailong wang commented on FLINK-15434:
--------------------------------------

Hi [~gjy] , Thank you for assigning this ticket to me. I will change 
{code:java}
final JobMaster jobMaster = createJobMaster(
   configuration,
   jobGraph,
   haServices,
   new TestingJobManagerSharedServicesBuilder().build());
{code}
to 
{code:java}
final JobMaster jobMaster = createJobMaster(
   configuration,
   jobGraph,
   haServices,
   new TestingJobManagerSharedServicesBuilder().build(),
   heartbeatServices);
{code}
BTW, should we do the same  in testReconnectionAfterDisconnect() method?

 

> testResourceManagerConnectionAfterRegainingLeadership test fail when run  
> azure
> -------------------------------------------------------------------------------
>
>                 Key: FLINK-15434
>                 URL: https://issues.apache.org/jira/browse/FLINK-15434
>             Project: Flink
>          Issue Type: Bug
>          Components: Tests
>    Affects Versions: 1.9.1
>            Reporter: hailong wang
>            Priority: Critical
>             Fix For: 1.10.0
>
>
> Error message
> Expected: <b65797325db6323dd5f8bdfeeaa18467>
>  but: was <57f975298d116a9d7623f5a844ce6502>
>  
> Stack trace
> java.lang.AssertionError: Expected: <b65797325db6323dd5f8bdfeeaa18467> but: 
> was <57f975298d116a9d7623f5a844ce6502> at 
> org.apache.flink.runtime.jobmaster.JobMasterTest.testResourceManagerConnectionAfterRegainingLeadership(JobMasterTest.java:1033)



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to