[
https://issues.apache.org/jira/browse/FLINK-19051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321366#comment-17321366
]
Flink Jira Bot commented on FLINK-19051:
----------------------------------------
This issue and all of its Sub-Tasks have not been updated for 180 days. So, it
has been labeled "stale-minor". If you are still affected by this bug or are
still interested in this issue, please give an update and remove the label. In
7 days the issue will be closed automatically.
> 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)
