Repository: flink Updated Branches: refs/heads/master 5af463a9c -> f1b2b83d6
[hotfix][runtime] Checkstyle changes in TaskStateSnapshot Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/79b916c7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/79b916c7 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/79b916c7 Branch: refs/heads/master Commit: 79b916c730455340c193550738fb66af9f70fd85 Parents: 5af463a Author: Piotr Nowojski <piotr.nowoj...@gmail.com> Authored: Fri Aug 25 13:59:36 2017 +0200 Committer: Stefan Richter <s.rich...@data-artisans.com> Committed: Mon Sep 25 17:53:42 2017 +0200 ---------------------------------------------------------------------- .../org/apache/flink/runtime/checkpoint/TaskStateSnapshot.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/79b916c7/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateSnapshot.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateSnapshot.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateSnapshot.java index c416f3f..28edc63 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateSnapshot.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateSnapshot.java @@ -47,7 +47,9 @@ public class TaskStateSnapshot implements CompositeStateHandle { private static final long serialVersionUID = 1L; - /** Mapping from an operator id to the state of one subtask of this operator */ + /** + * Mapping from an operator id to the state of one subtask of this operator. + */ private final Map<OperatorID, OperatorSubtaskState> subtaskStatesByOperatorID; public TaskStateSnapshot() { @@ -55,7 +57,7 @@ public class TaskStateSnapshot implements CompositeStateHandle { } public TaskStateSnapshot(int size) { - this(new HashMap<OperatorID, OperatorSubtaskState>(size)); + this(new HashMap<>(size)); } public TaskStateSnapshot(Map<OperatorID, OperatorSubtaskState> subtaskStatesByOperatorID) {
