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);