correct

ydb-platform · Nov 12, 2024 · e679e7c · e679e7c
1 parent e78742e
commit e679e7c
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/ydb/core/tx/columnshard/columnshard__write.cpp b/ydb/core/tx/columnshard/columnshard__write.cpp
@@ -589,10 +589,9 @@ void TColumnShard::Handle(NEvents::TDataEvents::TEvWrite::TPtr& ev, const TActor
         pathId, lockId, cookie, granuleShardingVersionId, *mType, AppDataVerified().FeatureFlags.GetEnableWritePortionsOnInsert());
     Y_ABORT_UNLESS(writeOperation);
     writeOperation->SetBehaviour(behaviour);
-    const NOlap::TSnapshot applyToSnapshot(record.GetMvccSnapshot().GetStep(), record.GetMvccSnapshot().GetTxId());
     NOlap::TWritingContext wContext(
         pathId, SelfId(), schema, StoragesManager, Counters.GetIndexationCounters().SplitterCounters,
-        Counters.GetCSCounters().WritingCounters, applyToSnapshot);
+        Counters.GetCSCounters().WritingCounters, GetCurrentSnapshotForInternalModification());
     arrowData->SetSeparationPoints(GetIndexAs<NOlap::TColumnEngineForLogs>().GetGranulePtrVerified(pathId)->GetBucketPositions());
     writeOperation->Start(*this, arrowData, source, wContext);
 }