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/03/23 08:06:41 UTC
[2/2] flink git commit: [hotfix] Remove unnecessary transient
modifiers in CheckpointStatsTracker
[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/93d99fdb
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/93d99fdb
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/93d99fdb
Branch: refs/heads/master
Commit: 93d99fdb39d6c2bd7715d7b6d4352ce3d895d9f8
Parents: b550ac6
Author: Till Rohrmann <tr...@apache.org>
Authored: Thu Mar 22 17:15:36 2018 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Thu Mar 22 19:04:22 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/93d99fdb/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.