(ignite-3) branch main updated: IGNITE-24483 Sql. ItJdbcMultiStatementSelfTest.testAutoCommitFalseTxControlStatementsNotSupported is flaky (#5264)

[zstan]

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 <stanilov...@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);