[FLINK-19051] Exception message should be reserved in log When the Job Manager failed

• Type: Improvement
• Status: Reopened
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.11.1, 1.12.0
• Component/s: Runtime / Task
• Assignee: Unassigned
• Reporter: zhuxiaoshang
• Created: 26/Aug/20 07:37
• Updated: 29/Jul/21 07:38

Description

protected void closeJobManagerConnection(JobID jobId, Exception cause) {
   JobManagerRegistration jobManagerRegistration = jobManagerRegistrations.remove(jobId);

   if (jobManagerRegistration != null) {
      final ResourceID jobManagerResourceId = jobManagerRegistration.getJobManagerResourceID();
      final JobMasterGateway jobMasterGateway = jobManagerRegistration.getJobManagerGateway();
      final JobMasterId jobMasterId = jobManagerRegistration.getJobMasterId();

      log.info("Disconnect job manager {}@{} for job {} from the resource manager.",
         jobMasterId,
         jobMasterGateway.getAddress(),
         jobId);

      jobManagerHeartbeatManager.unmonitorTarget(jobManagerResourceId);

      jmResourceIdRegistrations.remove(jobManagerResourceId);

      // tell the job manager about the disconnect
      jobMasterGateway.disconnectResourceManager(getFencingToken(), cause);
   } else {
      log.debug("There was no registered job manager for job {}.", jobId);
   }

Exception message should be reserved in log.