[flink] branch release-1.15 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.15
in repository https://gitbox.apache.org/repos/asf/flink.git


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

commit df3ab6c72f991e9b28f2c2566e95b23bdfb7cf9c
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))
                 + '}';
     }
 }