(ignite-3) branch main updated: IGNITE-26955 Fix executor usage in LeaseNegotiator#log (#6907)

[tkalkirill]

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

tkalkirill pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new 779a8c45e08 IGNITE-26955 Fix executor usage in LeaseNegotiator#log 
(#6907)
779a8c45e08 is described below

commit 779a8c45e0828d5b16e85e6909d11718e154a83d
Author: Kirill Tkalenko <tkalkir...@yandex.ru>
AuthorDate: Thu Nov 6 13:58:13 2025 +0300

    IGNITE-26955 Fix executor usage in LeaseNegotiator#log (#6907)
---
 .../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);
     }
 
     /**