[hotfix] Remove unnecessary transient modifiers in CheckpointStatsTracker
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6e23a88d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6e23a88d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6e23a88d Branch: refs/heads/release-1.5 Commit: 6e23a88d43807fcab0c2256abef4bbc9af9324a6 Parents: 9c105f2 Author: Till Rohrmann <[email protected]> Authored: Thu Mar 22 17:15:36 2018 +0100 Committer: Till Rohrmann <[email protected]> Committed: Fri Mar 23 09:07:20 2018 +0100 ---------------------------------------------------------------------- .../flink/runtime/checkpoint/CheckpointStatsTracker.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/6e23a88d/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java index e6386ad..9be1f69 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java @@ -59,7 +59,7 @@ public class CheckpointStatsTracker { * from a single Thread at a time and there can be multiple concurrent read * accesses to the latest stats snapshot. * - * Currently, writes are executed by whatever Thread executes the coordinator + * <p>Currently, writes are executed by whatever Thread executes the coordinator * actions (which already happens in locked scope). Reads can come from * multiple concurrent Netty event loop Threads of the web runtime monitor. */ @@ -81,7 +81,7 @@ public class CheckpointStatsTracker { private final CheckpointStatsHistory history; /** The job vertices taking part in the checkpoints. */ - private final transient List<ExecutionJobVertex> jobVertices; + private final List<ExecutionJobVertex> jobVertices; /** The latest restored checkpoint. */ @Nullable @@ -99,7 +99,7 @@ public class CheckpointStatsTracker { /** The latest completed checkpoint. Used by the latest completed checkpoint metrics. */ @Nullable - private volatile transient CompletedCheckpointStats latestCompletedCheckpoint; + private volatile CompletedCheckpointStats latestCompletedCheckpoint; /** * Creates a new checkpoint stats tracker.
