fix

apache · Apr 13, 2024 · 297ae38 · 297ae38
1 parent b9b28d8
commit 297ae38
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/FlightSqlClient.java b/java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/FlightSqlClient.java
@@ -1055,7 +1055,9 @@ public FlightInfo execute(final CallOption... options) {
  .toByteArray());
 
  if (parameterBindingRoot != null && parameterBindingRoot.getRowCount() > 0) {
- putParameters(descriptor, options);
+ try (final SyncPutListener listener = putParameters(descriptor, options)) {
+ listener.getResult();
+ }
  }
 
  return client.getInfo(descriptor, options);