[flink] branch release-1.14 updated: [FLINK-26575][checkpoint] Improve the info message when restoring keyed state backend

[tangyun]

This is an automated email from the ASF dual-hosted git repository.

tangyun pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.14 by this push:
     new 9b81855  [FLINK-26575][checkpoint] Improve the info message when 
restoring keyed state backend
9b81855 is described below

commit 9b818553e587eda03b44676657ccee2d7c0470b5
Author: Yun Tang <myas...@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))
                 + '}';
     }
 }