(ignite-3) branch main updated: IGNITE-22191 Fixed case null MvPartitionStorage in IndexBuildController (#3739)

[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 cf85b69c35 IGNITE-22191 Fixed case null MvPartitionStorage in 
IndexBuildController (#3739)
cf85b69c35 is described below

commit cf85b69c35e8adf0999936523c2edd2371dc9a19
Author: Kirill Tkalenko <tkalkir...@yandex.ru>
AuthorDate: Fri May 10 14:38:52 2024 +0300

    IGNITE-22191 Fixed case null MvPartitionStorage in IndexBuildController 
(#3739)
---
 .../ignite/internal/index/IndexBuildController.java       | 15 +++++++++++++--
 1 file changed, 13 insertions(+), 2 deletions(-)

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 e5ec762026..934ce5511a 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 @@ class IndexBuildController implements ManuallyCloseable {
     ) {
         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 @@ class IndexBuildController implements ManuallyCloseable {
     ) {
         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 @@ class IndexBuildController implements ManuallyCloseable {
         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;
     }