Caizhi Weng created FLINK-13880:
-----------------------------------
Summary: The behavior of JobExecutionResult.getAccumulatorResult
does not match its java doc
Key: FLINK-13880
URL: https://issues.apache.org/jira/browse/FLINK-13880
Project: Flink
Issue Type: Bug
Reporter: Caizhi Weng
The java doc of `JobExecutionResult.getAccumulatorResult` states that "Returns
\{@code null}, if no accumulator with that name was produced", but actually an
NPE will be triggered if no accumulator with that name is produced.
I'm going to rewrite the `getAccumulatorResult` method to the following:
{code:java}
public <T> T getAccumulatorResult(String accumulatorName) {
OptionalFailure<Object> result =
this.accumulatorResults.get(accumulatorName);
if (result != null) {
return (T) result.getUnchecked();
} else {
return null;
}
}
{code}
Please assign this issue to me if this solution is acceptable.
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
