[
https://issues.apache.org/jira/browse/FLINK-19051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-19051:
-----------------------------------
Labels: stale-minor (was: )
> 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: zhuxiaoshang
> Priority: Minor
> Labels: stale-minor
>
> {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)
