commit cf85b69c35e8adf0999936523c2edd2371dc9a19
author Kirill Tkalenko <tkalkirill@yandex.ru> Fri May 10 14:38:52 2024 +0300
committer GitHub <noreply@github.com> Fri May 10 14:38:52 2024 +0300
tree 91133cd1fb88fc1baf6a679df5c4265ccaeb9f5c
parent 348f68b10b8dc4246e8b379edf683ef66f3f5472

IGNITE-22191 Fixed case null MvPartitionStorage in IndexBuildController (#3739)

modules/index/src/main/java/org/apache/ignite/internal/index/IndexBuildController.java

diff --git a/modules/index/src/main/java/org/apache/ignite/internal/index/IndexBuildController.java b/modules/index/src/main/java/org/apache/ignite/internal/index/IndexBuildController.java
index e5ec762..934ce55 100644
--- a/modules/index/src/main/java/org/apache/ignite/internal/index/IndexBuildController.java
+++ b/modules/index/src/main/java/org/apache/ignite/internal/index/IndexBuildController.java
@@ -306,6 +306,11 @@
     ) {
         MvPartitionStorage mvPartition = mvPartitionStorage(mvTableStorage, replicaId);
 
+        // TODO: IGNITE-22202 Deal with this situation
+        if (mvPartition == null) {
+            return;
+        }
+
         IndexStorage indexStorage = indexStorage(mvTableStorage, replicaId, indexDescriptor);
 
         indexBuilder.scheduleBuildIndex(
@@ -329,6 +334,11 @@
     ) {
         MvPartitionStorage mvPartition = mvPartitionStorage(mvTableStorage, replicaId);
 
+        // TODO: IGNITE-22202 Deal with this situation
+        if (mvPartition == null) {
+            return;
+        }
+
         IndexStorage indexStorage = indexStorage(mvTableStorage, replicaId, indexDescriptor);
 
         indexBuilder.scheduleBuildIndexAfterDisasterRecovery(
@@ -355,10 +365,11 @@
         return replicaMeta.getStartTime().longValue();
     }
 
-    private static MvPartitionStorage mvPartitionStorage(MvTableStorage mvTableStorage, TablePartitionId replicaId) {
+    private static @Nullable MvPartitionStorage mvPartitionStorage(MvTableStorage mvTableStorage, TablePartitionId replicaId) {
         MvPartitionStorage mvPartition = mvTableStorage.getMvPartition(replicaId.partitionId());
 
-        assert mvPartition != null : replicaId;
+        // TODO: IGNITE-22202 Deal with this situation
+        // assert mvPartition != null : replicaId;
 
         return mvPartition;
     }