diff --git a/presto-native-execution/presto_cpp/main/operators/BroadcastFactory.cpp b/presto-native-execution/presto_cpp/main/operators/BroadcastFactory.cpp
index 8c48f5f02ffc8..7dcfee2cbfad3 100644
--- a/presto-native-execution/presto_cpp/main/operators/BroadcastFactory.cpp
+++ b/presto-native-execution/presto_cpp/main/operators/BroadcastFactory.cpp
@@ -130,7 +130,8 @@ void BroadcastFileWriter::write(const RowVectorPtr& rowVector) {
   const IndexRange allRows{0, numRows};
 
   auto arena = std::make_unique<StreamArena>(pool_);
-  auto serializer = serde_->createSerializer(inputType_, numRows, arena.get());
+  auto serializer =
+      serde_->createIterativeSerializer(inputType_, numRows, arena.get());
 
   serializer->append(rowVector, folly::Range(&allRows, 1));
   maxSerializedSize_ += serializer->maxSerializedSize();