Ensures no concurrent submit chunk when max_parallelism=1

PiperOrigin-RevId: 516513330
google · Mar 14, 2023 · 5e60cb1 · 5e60cb1
1 parent 9474099
commit 5e60cb1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cpp/array_record_writer.cc b/cpp/array_record_writer.cc
@@ -425,7 +425,7 @@ bool ArrayRecordWriterBase::WriteRecordImpl(Record&& record) {
       return false;
     }
     chunk_encoder_ = CreateEncoder();
-    if (pool_) {
+    if (pool_ && options_.max_parallelism().value() > 1) {
       std::shared_ptr<riegeli::ChunkEncoder> shared_encoder =
           std::move(encoder);
       submit_chunk_callback_->TrackConcurrentChunkWriters();