You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2022/09/23 13:18:23 UTC
[ignite-3] 01/02: WIP.
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 <an...@gmail.com>
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());