You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2017/01/31 13:03:26 UTC
[2/6] flink git commit: [FLINK-5644] [runtime] Remove metric:
Task#lastCheckpointSize
[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/f3930510
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f3930510
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f3930510
Branch: refs/heads/master
Commit: f3930510c6f54a23f532b8f79aed16ee140e3ce5
Parents: 99aed0b
Author: zentol <ch...@apache.org>
Authored: Wed Jan 25 14:59:07 2017 +0100
Committer: Stephan Ewen <se...@apache.org>
Committed: Tue Jan 31 14:02:44 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/f3930510/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 705dfca..63843bb 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;
@@ -174,8 +173,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;
@@ -236,13 +233,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();