This is an automated email from the ASF dual-hosted git repository. tkalkirill pushed a commit to branch ignite-26955 in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit 09195aa75b4db9c7579ae93812277ef072ed79fa Author: Kirill Tkalenko <[email protected]> AuthorDate: Thu Nov 6 13:01:25 2025 +0300 IGNITE-26955 wip --- .../ignite/internal/placementdriver/negotiation/LeaseNegotiator.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/negotiation/LeaseNegotiator.java b/modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/negotiation/LeaseNegotiator.java index d2764b80060..e96bc9538cd 100644 --- a/modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/negotiation/LeaseNegotiator.java +++ b/modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/negotiation/LeaseNegotiator.java @@ -18,7 +18,6 @@ package org.apache.ignite.internal.placementdriver.negotiation; import static org.apache.ignite.internal.lang.IgniteStringFormatter.format; -import static org.apache.ignite.internal.logger.Loggers.toThrottledLogger; import static org.apache.ignite.internal.placementdriver.negotiation.LeaseAgreement.UNDEFINED_AGREEMENT; import static org.apache.ignite.internal.util.ExceptionUtils.hasCause; @@ -42,7 +41,7 @@ public class LeaseNegotiator { private static final PlacementDriverMessagesFactory PLACEMENT_DRIVER_MESSAGES_FACTORY = new PlacementDriverMessagesFactory(); /** The logger. */ - private final IgniteThrottledLogger log = toThrottledLogger(Loggers.forClass(LeaseNegotiator.class), Runnable::run); + private final IgniteThrottledLogger log; /** Lease agreements which are in progress of negotiation. */ private final Map<ReplicationGroupId, LeaseAgreement> leaseToNegotiate = new ConcurrentHashMap<>(); @@ -61,6 +60,8 @@ public class LeaseNegotiator { Executor throttledLogExecutor ) { this.clusterService = clusterService; + + log = Loggers.toThrottledLogger(Loggers.forClass(LeaseNegotiator.class), throttledLogExecutor); } /**
