[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16320328#comment-16320328
]
ASF GitHub Bot commented on FLINK-8234:
---------------------------------------
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r160692953
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -956,23 +958,29 @@ private void jobStatusChanged(
"The job is
registered as 'FINISHED (successful), but this notification describes " +
"a failure,
since the resulting accumulators could not be fetched.", e);
- executor.execute(()
->jobCompletionActions.jobFailed(exception));
+ executor.execute(() ->
jobCompletionActions.jobFailed(builder
+
.serializedThrowable(new SerializedThrowable(exception))
+ .build()));
}
break;
case CANCELED: {
final JobExecutionException exception =
new JobExecutionException(
jobID, "Job was cancelled.",
new Exception("The job was cancelled"));
- executor.execute(() ->
jobCompletionActions.jobFailed(exception));
+ executor.execute(() ->
jobCompletionActions.jobFailed(builder
+ .serializedThrowable(new
SerializedThrowable(exception))
+ .build()));
break;
}
case FAILED: {
final Throwable unpackedError =
SerializedThrowable.get(error, userCodeLoader);
--- End diff --
True. Not sure where I was looking at.
> Cache JobExecutionResult from finished JobManagerRunners
> --------------------------------------------------------
>
> Key: FLINK-8234
> URL: https://issues.apache.org/jira/browse/FLINK-8234
> Project: Flink
> Issue Type: Sub-task
> Components: Distributed Coordination
> Affects Versions: 1.5.0
> Reporter: Till Rohrmann
> Assignee: Gary Yao
> Priority: Blocker
> Labels: flip-6
> Fix For: 1.5.0
>
>
> In order to serve the {{JobExecutionResults}} we have to cache them in the
> {{Dispatcher}} after the {{JobManagerRunner}} has finished. The cache should
> have a configurable size and should periodically clean up stale entries in
> order to avoid memory exhaustion.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
