You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2021/02/18 09:14:55 UTC
[flink] 07/12: [hotfix][coordination] Add
StateWithExecutionGraph#reportCheckpointMetrics
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 687c8ffca4eaab7d3fde48b5873338da7363f030
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Wed Feb 10 16:25:03 2021 +0100
[hotfix][coordination] Add StateWithExecutionGraph#reportCheckpointMetrics
---
.../runtime/scheduler/declarative/StateWithExecutionGraph.java | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/declarative/StateWithExecutionGraph.java b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/declarative/StateWithExecutionGraph.java
index f34752e..ce29462 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/declarative/StateWithExecutionGraph.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/declarative/StateWithExecutionGraph.java
@@ -180,6 +180,14 @@ abstract class StateWithExecutionGraph implements State {
executionGraphHandler.declineCheckpoint(decline);
}
+ void reportCheckpointMetrics(
+ ExecutionAttemptID executionAttemptID,
+ long checkpointId,
+ CheckpointMetrics checkpointMetrics) {
+ executionGraphHandler.reportCheckpointMetrics(
+ executionAttemptID, checkpointId, checkpointMetrics);
+ }
+
void updateAccumulators(AccumulatorSnapshot accumulatorSnapshot) {
executionGraph.updateAccumulators(accumulatorSnapshot);
}