Repository: flink Updated Branches: refs/heads/release-1.2 65b1da8c5 -> 3e59d838f
[FLINK-5644] [runtime] Remove metric: Task#lastCheckpointSize This closes #3214 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3e59d838 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3e59d838 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3e59d838 Branch: refs/heads/release-1.2 Commit: 3e59d838fe7554c3431e366ad8305aa2d0585bde Parents: 9d6bf72 Author: zentol <[email protected]> Authored: Wed Jan 25 14:59:07 2017 +0100 Committer: Stephan Ewen <[email protected]> Committed: Tue Jan 31 14:04:47 2017 +0100 ---------------------------------------------------------------------- .../apache/flink/streaming/runtime/tasks/StreamTask.java | 10 ---------- 1 file changed, 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/3e59d838/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java index 1b9777a..cdcd6b4 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java @@ -24,7 +24,6 @@ import org.apache.flink.configuration.ConfigConstants; import org.apache.flink.configuration.Configuration; import org.apache.flink.configuration.IllegalConfigurationException; import org.apache.flink.core.fs.CloseableRegistry; -import org.apache.flink.metrics.Gauge; import org.apache.flink.runtime.checkpoint.CheckpointMetaData; import org.apache.flink.runtime.checkpoint.SubtaskState; import org.apache.flink.runtime.execution.CancelTaskException; @@ -173,8 +172,6 @@ public abstract class StreamTask<OUT, OP extends StreamOperator<OUT>> /** Flag to mark this task as canceled */ private volatile boolean canceled; - private long lastCheckpointSize = 0; - /** Thread pool for async snapshot workers */ private ExecutorService asyncOperationsThreadPool; @@ -235,13 +232,6 @@ public abstract class StreamTask<OUT, OP extends StreamOperator<OUT>> operatorChain = new OperatorChain<>(this); headOperator = operatorChain.getHeadOperator(); - getEnvironment().getMetricGroup().gauge("lastCheckpointSize", new Gauge<Long>() { - @Override - public Long getValue() { - return StreamTask.this.lastCheckpointSize; - } - }); - // task specific initialization init();
