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)
