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

[Shang Yuanchun (Jira)]

Pua created FLINK-19051:
---------------------------

             Summary: Exception message should be reserved in log When the Job Manager failed
                 Key: FLINK-19051
                 URL: https://issues.apache.org/jira/browse/FLINK-19051
             Project: Flink
          Issue Type: Improvement
          Components: Runtime / Task
    Affects Versions: 1.11.1, 1.12.0
            Reporter: Pua


{code:java}
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);
   }
{code}
Exception message should be reserved in log.



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