[-] the UseDeduplication flag was reset in the TPartitionWriter optio…

…ns (ydb-platform#1256)
GrigoriyPA · Jan 24, 2024 · 72e7bfc · 72e7bfc
1 parent 526ec53
commit 72e7bfc
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/ydb/services/deprecated/persqueue_v0/grpc_pq_write_actor.cpp b/ydb/services/deprecated/persqueue_v0/grpc_pq_write_actor.cpp
@@ -483,8 +483,7 @@ void TWriteSessionActor::ProceedPartition(const ui32 partition, const TActorCont
     }
 
     TPartitionWriterOpts opts;
-    opts.WithDeduplication(false)
-        .WithSourceId(SourceId);
+    opts.WithSourceId(SourceId);
     Writer = ctx.RegisterWithSameMailbox(NPQ::CreatePartitionWriter(ctx.SelfID, PartitionTabletId, Partition, opts));
     State = ES_WAIT_WRITER_INIT;