Subject: [PATCH] pk violations
---
Index: modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlQueryProcessor.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
diff --git a/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlQueryProcessor.java b/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlQueryProcessor.java
--- a/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlQueryProcessor.java	(revision adff03d1d7d2598a3c33bdaa65d6ac33465db04c)
+++ b/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlQueryProcessor.java	(date 1703061581496)
@@ -625,6 +625,7 @@
                         fut = fut.thenCompose(
                                 cursor -> callback.prefetchFuture().whenComplete((res, ex) -> {
                                     if (ex != null) {
+                                        txWrapper.rollback(ex);
                                         cursor.closeAsync();
                                     }
                                 }).thenApply(ignore -> cursor)