You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/01/11 16:15:04 UTC
[5/5] flink git commit: [hotfix] Clean up ExecutionGraph
[hotfix] Clean up ExecutionGraph
- Remove unnecessary throws clause.
- Format whitespace.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d7ee6033
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d7ee6033
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d7ee6033
Branch: refs/heads/master
Commit: d7ee60330ae91700d7b2c06eec863e3c4b092222
Parents: 86892b8
Author: gyao <ga...@data-artisans.com>
Authored: Wed Dec 20 14:44:26 2017 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Thu Jan 11 17:01:41 2018 +0100
----------------------------------------------------------------------
.../org/apache/flink/runtime/executiongraph/ExecutionGraph.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/d7ee6033/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
index a02a687..202839c 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
@@ -721,7 +721,7 @@ public class ExecutionGraph implements AccessExecutionGraph, Archiveable<Archive
* Merges all accumulator results from the tasks previously executed in the Executions.
* @return The accumulator map
*/
- public Map<String, Accumulator<?,?>> aggregateUserAccumulators() {
+ public Map<String, Accumulator<?, ?>> aggregateUserAccumulators() {
Map<String, Accumulator<?, ?>> userAccumulators = new HashMap<>();
@@ -738,7 +738,7 @@ public class ExecutionGraph implements AccessExecutionGraph, Archiveable<Archive
/**
* Gets the accumulator results.
*/
- public Map<String, Object> getAccumulators() throws IOException {
+ public Map<String, Object> getAccumulators() {
Map<String, Accumulator<?, ?>> accumulatorMap = aggregateUserAccumulators();