This is an automated email from the ASF dual-hosted git repository. amashenkov pushed a commit to branch ignite-17686 in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit 2ed0e7d56c40a2d6c42bfef58c036cf03b180c15 Author: amashenkov <[email protected]> AuthorDate: Fri Sep 23 15:54:40 2022 +0300 WIP. --- .../apache/ignite/internal/sql/engine/exec/ddl/DdlCommandHandler.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ddl/DdlCommandHandler.java b/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ddl/DdlCommandHandler.java index 5ff26fa0ec..89c82a7548 100644 --- a/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ddl/DdlCommandHandler.java +++ b/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ddl/DdlCommandHandler.java @@ -299,6 +299,8 @@ public class DdlCommandHandler { return tableManager.alterTableAsync( fullName, chng -> chng.changeColumns(cols -> { + ret.set(true); // Reset state if closure have been restarted. + Map<String, String> colNamesToOrders = columnOrdersToNames(chng.columns()); List<ColumnDefinition> colsDef0; @@ -379,6 +381,8 @@ public class DdlCommandHandler { return tableManager.alterTableAsync( fullName, chng -> chng.changeColumns(cols -> { + ret.set(true); // Reset state if closure have been restarted. + PrimaryKeyView priKey = chng.primaryKey(); Map<String, String> colNamesToOrders = columnOrdersToNames(chng.columns());
