Rollback uncommitted columns in cancelRow()

mtopolnik · mtopolnik · commit e63cac9a75e1 · 2026-03-31T17:10:29.000+02:00
diff --git a/core/src/main/java/io/questdb/client/cutlass/qwp/client/QwpWebSocketSender.java b/core/src/main/java/io/questdb/client/cutlass/qwp/client/QwpWebSocketSender.java
@@ -376,6 +376,7 @@ public void cancelRow() {
         checkNotClosed();
         if (currentTableBuffer != null) {
             currentTableBuffer.cancelCurrentRow();
+            currentTableBuffer.rollbackUncommittedColumns();
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -376,6 +376,7 @@ public void cancelRow() {`
`376`	`376`	`checkNotClosed();`
`377`	`377`	`if (currentTableBuffer != null) {`
`378`	`378`	`currentTableBuffer.cancelCurrentRow();`
	`379`	`+ currentTableBuffer.rollbackUncommittedColumns();`
`379`	`380`	`}`
`380`	`381`	`}`
`381`	`382`