You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ta...@apache.org on 2022/03/31 02:50:14 UTC
[flink] branch master updated: [FLINK-26575][checkpoint] Improve the info message when restoring keyed state backend
This is an automated email from the ASF dual-hosted git repository.
tangyun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new d8f6279 [FLINK-26575][checkpoint] Improve the info message when restoring keyed state backend
d8f6279 is described below
commit d8f6279c14236de832566b1ff97053e79e1e1414
Author: Yun Tang <my...@live.com>
AuthorDate: Thu Mar 10 15:58:08 2022 +0800
[FLINK-26575][checkpoint] Improve the info message when restoring keyed state backend
---
.../main/java/org/apache/flink/runtime/state/KeyGroupRangeOffsets.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupRangeOffsets.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupRangeOffsets.java
index 0d9046a..7ba4ac8 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupRangeOffsets.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupRangeOffsets.java
@@ -216,8 +216,7 @@ public class KeyGroupRangeOffsets implements Iterable<Tuple2<Integer, Long>>, Se
return "KeyGroupRangeOffsets{"
+ "keyGroupRange="
+ keyGroupRange
- + ", offsets="
- + Arrays.toString(offsets)
+ + (offsets.length > 10 ? "" : ", offsets=" + Arrays.toString(offsets))
+ '}';
}
}