From ac885ffc82479ab3e84bc5c57ffede65927ad955 Mon Sep 17 00:00:00 2001
From: zentol <chesnay@apache.org>
Date: Wed, 25 Jan 2017 14:59:07 +0100
Subject: [PATCH] [FLINK-5644] Remove metric: Task#lastCheckpointSize

---
 .../flink/streaming/runtime/tasks/StreamTask.java      | 10 ----------
 1 file changed, 10 deletions(-)

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 7647fbbf8ac56..3c78b0d1b4a69 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.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 final void invoke() throws Exception {
 			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();