You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by zs...@apache.org on 2025/02/28 06:05:29 UTC
(ignite-3) branch main updated: IGNITE-24483 Sql. ItJdbcMultiStatementSelfTest.testAutoCommitFalseTxControlStatementsNotSupported is flaky (#5264)
This is an automated email from the ASF dual-hosted git repository.
zstan 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 2490886d2e0 IGNITE-24483 Sql. ItJdbcMultiStatementSelfTest.testAutoCommitFalseTxControlStatementsNotSupported is flaky (#5264)
2490886d2e0 is described below
commit 2490886d2e066279ba982300d985e6a535603e92
Author: Evgeniy Stanilovskiy <st...@gmail.com>
AuthorDate: Fri Feb 28 09:05:22 2025 +0300
IGNITE-24483 Sql. ItJdbcMultiStatementSelfTest.testAutoCommitFalseTxControlStatementsNotSupported is flaky (#5264)
---
.../ignite/internal/sql/engine/exec/fsm/MultiStatementHandler.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/MultiStatementHandler.java b/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/MultiStatementHandler.java
index d0599f1e315..f11756e42ae 100644
--- a/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/MultiStatementHandler.java
+++ b/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/fsm/MultiStatementHandler.java
@@ -34,6 +34,7 @@ import org.apache.ignite.internal.sql.engine.AsyncSqlCursor;
import org.apache.ignite.internal.sql.engine.AsyncSqlCursorImpl;
import org.apache.ignite.internal.sql.engine.InternalSqlRow;
import org.apache.ignite.internal.sql.engine.SqlQueryType;
+import org.apache.ignite.internal.sql.engine.TxControlInsideExternalTxNotSupportedException;
import org.apache.ignite.internal.sql.engine.exec.TransactionTracker;
import org.apache.ignite.internal.sql.engine.exec.fsm.QueryExecutor.ParsedResultWithNextCursorFuture;
import org.apache.ignite.internal.sql.engine.sql.ParsedResult;
@@ -239,6 +240,10 @@ class MultiStatementHandler {
});
}
});
+ } catch (TxControlInsideExternalTxNotSupportedException txEx) {
+ scriptTxContext.onError(txEx);
+
+ cursorFuture.completeExceptionally(txEx);
} catch (Throwable e) {
scriptTxContext.onError(e);