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 5446df3bac IGNITE-22714 Use IndexMeta in PartitionReplicaListener 
(#4077)
5446df3bac is described below

commit 5446df3bac67f217e8516d2b6068a4a42a8bf279
Author: Kirill Tkalenko <[email protected]>
AuthorDate: Fri Jul 12 14:24:45 2024 +0300

    IGNITE-22714 Use IndexMeta in PartitionReplicaListener (#4077)
---
 .../table/distributed/replicator/PartitionReplicaListener.java      | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
 
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
index 8954ff184c..5529df73cd 100644
--- 
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
+++ 
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
@@ -4047,7 +4047,11 @@ public class PartitionReplicaListener implements 
ReplicaListener {
         CatalogIndexDescriptor indexDescriptor = 
latestIndexDescriptorInBuildingStatus(catalogService, tableId());
 
         if (indexDescriptor != null) {
-            
txRwOperationTracker.updateMinAllowedCatalogVersionForStartOperation(indexDescriptor.txWaitCatalogVersion());
+            IndexMeta indexMeta = 
indexMetaStorage.indexMeta(indexDescriptor.id());
+
+            assert indexMeta != null : indexDescriptor.id();
+
+            
txRwOperationTracker.updateMinAllowedCatalogVersionForStartOperation(indexMeta.statusChange(REGISTERED).catalogVersion());
         }
 
         catalogService.listen(CatalogEvent.INDEX_BUILDING, 
indexBuildingCatalogEventListener);

Reply via email to