[FLINK-13880][core] Correct the behavior of JobExecutionResult#getAcc…

…umulatorResult to match Javadoc This closes apache#11698
spotify · Apr 15, 2020 · 936cb65 · 936cb65
1 parent 0f83584
commit 936cb65
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/JobExecutionResult.java b/flink-core/src/main/java/org/apache/flink/api/common/JobExecutionResult.java
@@ -98,7 +98,12 @@ public long getNetRuntime(TimeUnit desiredUnit) {
  */
  @SuppressWarnings("unchecked")
  public <T> T getAccumulatorResult(String accumulatorName) {
- return (T) this.accumulatorResults.get(accumulatorName).getUnchecked();
+ OptionalFailure<Object> result = this.accumulatorResults.get(accumulatorName);
+ if (result != null) {
+ return (T) result.getUnchecked();
+ } else {
+ return null;
+ }
  }
 
  /**