diff --git a/java/flight/src/main/java/org/apache/arrow/flight/FlightClient.java b/java/flight/src/main/java/org/apache/arrow/flight/FlightClient.java
index ad7c7e28da242..74e73d1f83623 100644
--- a/java/flight/src/main/java/org/apache/arrow/flight/FlightClient.java
+++ b/java/flight/src/main/java/org/apache/arrow/flight/FlightClient.java
@@ -127,7 +127,7 @@ public ClientStreamListener startPut(FlightDescriptor descriptor, VectorSchemaRo
     // send the schema to start.
     ArrowMessage message = new ArrowMessage(descriptor.toProtocol(), root.getSchema());
     observer.onNext(message);
-    return new PutObserver(new VectorUnloader(root, true, false), observer, resultObserver.getFuture());
+    return new PutObserver(new VectorUnloader(root, true, true), observer, resultObserver.getFuture());
   }
 
   public FlightInfo getInfo(FlightDescriptor descriptor) {