(ignite-3) branch main updated: IGNITE-28006 Cleanup dead incomingSnapshotsExecutor from TableManager (#7695)

[ibessonov]

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

ibessonov 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 27b94ada56e IGNITE-28006 Cleanup dead incomingSnapshotsExecutor from 
TableManager (#7695)
27b94ada56e is described below

commit 27b94ada56e56054db588d2fdb19fe77fe9f5dac
Author: Viacheslav Blinov <da...@users.noreply.github.com>
AuthorDate: Tue Mar 3 16:11:54 2026 +0300

    IGNITE-28006 Cleanup dead incomingSnapshotsExecutor from TableManager 
(#7695)
---
 .../internal/table/distributed/TableManager.java       | 18 ------------------
 1 file changed, 18 deletions(-)

diff --git 
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableManager.java
 
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableManager.java
index 917eb932946..e8633d6ca16 100644
--- 
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableManager.java
+++ 
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableManager.java
@@ -65,9 +65,7 @@ import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.Executor;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
-import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.function.Function;
@@ -276,9 +274,6 @@ public class TableManager implements IgniteTablesInternal, 
IgniteComponent {
 
     private final FailureProcessor failureProcessor;
 
-    /** Incoming RAFT snapshots executor. */
-    private final ThreadPoolExecutor incomingSnapshotsExecutor;
-
     private final MvGc mvGc;
 
     private final LowWatermark lowWatermark;
@@ -460,18 +455,6 @@ public class TableManager implements IgniteTablesInternal, 
IgniteComponent {
         scanRequestExecutor = Executors.newSingleThreadExecutor(
                 IgniteThreadFactory.create(nodeName, "scan-query-executor", 
LOG, STORAGE_READ));
 
-        int cpus = Runtime.getRuntime().availableProcessors();
-
-        incomingSnapshotsExecutor = new ThreadPoolExecutor(
-                cpus,
-                cpus,
-                30,
-                TimeUnit.SECONDS,
-                new LinkedBlockingQueue<>(),
-                IgniteThreadFactory.create(nodeName, "incoming-raft-snapshot", 
LOG, STORAGE_READ, STORAGE_WRITE)
-        );
-        incomingSnapshotsExecutor.allowCoreThreadTimeOut(true);
-
         mvGc = new MvGc(nodeName, gcConfig, lowWatermark, failureProcessor);
 
         partitionReplicatorNodeRecovery = new PartitionReplicatorNodeRecovery(
@@ -1108,7 +1091,6 @@ public class TableManager implements 
IgniteTablesInternal, IgniteComponent {
                     mvGc,
                     fullStateTransferIndexChooser,
                     () -> shutdownAndAwaitTermination(scanRequestExecutor, 
shutdownTimeoutSeconds, TimeUnit.SECONDS),
-                    () -> 
shutdownAndAwaitTermination(incomingSnapshotsExecutor, shutdownTimeoutSeconds, 
TimeUnit.SECONDS),
                     () -> {
                         ScheduledExecutorService streamerFlushExecutor;