[flink] branch master updated: [FLINK-32141][checkpointing] turn down a log level in the SharedStateRegistry

[gu...@apache.org]

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

guoweijie 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 d94818e5f23 [FLINK-32141][checkpointing] turn down a log level in the SharedStateRegistry
d94818e5f23 is described below

commit d94818e5f2301200f3f1bd6bd094a79f4545bd84
Author: wangfeifan <zo...@163.com>
AuthorDate: Sun May 21 01:00:05 2023 +0800

    [FLINK-32141][checkpointing] turn down a log level in the SharedStateRegistry
---
 .../java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java
index 3a710428509..e2ebcc19108 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java
@@ -114,8 +114,7 @@ public class SharedStateRegistryImpl implements SharedStateRegistry {
                         registrationKey,
                         newHandle);
             } else if (Objects.equals(entry.stateHandle, newHandle)) {
-                // might be a bug but state backend is not required to use a place-holder
-                LOG.info(
+                LOG.trace(
                         "Duplicated registration under key {} with the new object: {}.",
                         registrationKey,
                         newHandle);