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 b68f771f3d IGNITE-22556 Fix exception in
IndexBuildController.requireMvTableStorageNonNull (#4033)
b68f771f3d is described below
commit b68f771f3de8d015ed8836a466b2bfbdab108dcd
Author: Kirill Tkalenko <[email protected]>
AuthorDate: Wed Jul 3 12:52:41 2024 +0300
IGNITE-22556 Fix exception in
IndexBuildController.requireMvTableStorageNonNull (#4033)
---
.../java/org/apache/ignite/internal/index/IndexBuildController.java | 5 +++++
1 file changed, 5 insertions(+)
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 29f7f9233f..7c5245c97c 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
@@ -185,6 +185,11 @@ class IndexBuildController implements ManuallyCloseable {
// metastore thread.
int catalogVersion = catalogService.latestCatalogVersion();
+ // TODO: IGNITE-22656 It is necessary not to generate an event
for a destroyed table by LWM
+ if (catalogService.table(primaryReplicaId.tableId(),
catalogVersion) == null) {
+ return nullCompletedFuture();
+ }
+
return getMvTableStorageFuture(parameters.causalityToken(),
primaryReplicaId)
.thenCompose(mvTableStorage ->
awaitPrimaryReplica(primaryReplicaId, parameters.startTime())
.thenAccept(replicaMeta ->
tryScheduleBuildIndexesForNewPrimaryReplica(
