fix

apache · Dec 30, 2024 · 91a601e · 91a601e
1 parent 6255927
commit 91a601e
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 6 deletions.
diff --git a/...tionTest/java/org/apache/ignite/internal/partition/replicator/ItReplicaLifecycleTest.java b/...tionTest/java/org/apache/ignite/internal/partition/replicator/ItReplicaLifecycleTest.java
@@ -155,6 +155,7 @@
 import org.apache.ignite.internal.raft.client.TopologyAwareRaftGroupServiceFactory;
 import org.apache.ignite.internal.raft.configuration.RaftConfiguration;
 import org.apache.ignite.internal.raft.storage.LogStorageFactory;
+import org.apache.ignite.internal.raft.storage.PersistentLogStorageFactory;
 import org.apache.ignite.internal.raft.storage.impl.LocalLogStorageFactory;
 import org.apache.ignite.internal.raft.util.SharedLogStorageFactoryUtils;
 import org.apache.ignite.internal.replicator.Replica;
@@ -974,7 +975,7 @@ class Node {
         private AtomicReference<Function<ReplicaRequest, ReplicationGroupId>> converter =
                 new AtomicReference<>(request -> request.groupId().asReplicationGroupId());
 
-        private final LogStorageFactory partitionsLogStorageFactory;
+        private final PersistentLogStorageFactory partitionsLogStorageFactory;
 
         private final LogStorageFactory msLogStorageFactory;
 

diff --git a/...raft/src/main/java/org/apache/ignite/internal/raft/util/SharedLogStorageFactoryUtils.java b/...raft/src/main/java/org/apache/ignite/internal/raft/util/SharedLogStorageFactoryUtils.java
@@ -39,11 +39,11 @@ public class SharedLogStorageFactoryUtils {
     private static final boolean LOGIT_STORAGE_ENABLED_PROPERTY_DEFAULT = false;
 
     /**
-     * Creates a LogStorageFactory with {@link DefaultLogStorageFactory} or {@link LogitLogStorageFactory} implementation depending on
-     * LOGIT_STORAGE_ENABLED_PROPERTY and fsync set to true.
+     * Creates a {@link PersistentLogStorageFactory} with {@link DefaultLogStorageFactory} or {@link LogitLogStorageFactory} implementation
+     * depending on LOGIT_STORAGE_ENABLED_PROPERTY and fsync set to true.
      */
     @TestOnly
-    public static LogStorageFactory create(String nodeName, Path logStoragePath) {
+    public static PersistentLogStorageFactory create(String nodeName, Path logStoragePath) {
         return create("test", nodeName, logStoragePath, new NoopDestroyStorageIntentStorage(), true);
     }
 

diff --git a/...c/integrationTest/java/org/apache/ignite/internal/runner/app/ItIgniteNodeRestartTest.java b/...c/integrationTest/java/org/apache/ignite/internal/runner/app/ItIgniteNodeRestartTest.java
@@ -176,6 +176,7 @@
 import org.apache.ignite.internal.raft.configuration.RaftConfiguration;
 import org.apache.ignite.internal.raft.server.impl.JraftServerImpl;
 import org.apache.ignite.internal.raft.storage.LogStorageFactory;
+import org.apache.ignite.internal.raft.storage.PersistentLogStorageFactory;
 import org.apache.ignite.internal.raft.storage.impl.LocalLogStorageFactory;
 import org.apache.ignite.internal.raft.util.SharedLogStorageFactoryUtils;
 import org.apache.ignite.internal.replicator.ReplicaManager;
@@ -407,7 +408,7 @@ private PartialNode startPartialNode(
 
         ComponentWorkingDir partitionsWorkDir = partitionsPath(systemConfiguration, dir);
 
-        LogStorageFactory partitionsLogStorageFactory =
+        PersistentLogStorageFactory partitionsLogStorageFactory =
                 SharedLogStorageFactoryUtils.create(clusterSvc.nodeName(), partitionsWorkDir.raftLogPath());
 
         RaftGroupOptionsConfigurer partitionRaftConfigurer =

diff --git a/...integrationTest/java/org/apache/ignite/internal/rebalance/ItRebalanceDistributedTest.java b/...integrationTest/java/org/apache/ignite/internal/rebalance/ItRebalanceDistributedTest.java
@@ -188,6 +188,7 @@
 import org.apache.ignite.internal.raft.configuration.RaftConfiguration;
 import org.apache.ignite.internal.raft.server.impl.JraftServerImpl;
 import org.apache.ignite.internal.raft.storage.LogStorageFactory;
+import org.apache.ignite.internal.raft.storage.PersistentLogStorageFactory;
 import org.apache.ignite.internal.raft.storage.impl.LocalLogStorageFactory;
 import org.apache.ignite.internal.raft.util.SharedLogStorageFactoryUtils;
 import org.apache.ignite.internal.replicator.Replica;
@@ -1159,7 +1160,7 @@ private class Node {
 
         private final ScheduledExecutorService rebalanceScheduler;
 
-        private final LogStorageFactory logStorageFactory;
+        private final PersistentLogStorageFactory logStorageFactory;
 
         private final LogStorageFactory cmgLogStorageFactory;