You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sk...@apache.org on 2021/09/07 07:45:17 UTC
[ignite-3] 02/02: IGNITE-15454 Fixed hanging test
SchemaChangeTableViewTest. Fixes #318
This is an automated email from the ASF dual-hosted git repository.
sk0x50 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit 2a26649b48c4b871ae81fd8bce51d80d5c4afdd9
Author: Kirill Gusakov <kg...@gmail.com>
AuthorDate: Tue Sep 7 10:43:40 2021 +0300
IGNITE-15454 Fixed hanging test SchemaChangeTableViewTest. Fixes #318
Signed-off-by: Slava Koptilin <sl...@gmail.com>
---
.../org/apache/ignite/internal/table/distributed/TableManager.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableManager.java b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableManager.java
index 28961cd..b40c611 100644
--- a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableManager.java
+++ b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableManager.java
@@ -507,12 +507,12 @@ public class TableManager extends Producer<TableEvent, TableEventParameters> imp
.exceptionally(e -> {
LOG.error("Failed to upgrade schema for a table [name=" + tblName + ", id=" + tblId + ']', e);
- onEvent(TableEvent.ALTER, new TableEventParameters(tblId, tblName), e);
+ onEvent(TableEvent.ALTER, new TableEventParameters(tblId, tblName, tbl), e);
return null;
})
.thenRun(() ->
- onEvent(TableEvent.ALTER, new TableEventParameters(tblId, tblName), null)
+ onEvent(TableEvent.ALTER, new TableEventParameters(tblId, tblName, tbl), null)
);
schemaMgr.listen(SchemaEvent.CHANGED, new EventListener<>() {