clean

ivanmorozov333 · ivanmorozov333 · commit 80d8d0e64164 · 2024-10-30T17:16:45.000+03:00
diff --git a/ydb/core/tx/columnshard/data_sharing/destination/transactions/tx_data_from_source.cpp b/ydb/core/tx/columnshard/data_sharing/destination/transactions/tx_data_from_source.cpp
@@ -17,11 +17,10 @@ bool TTxDataFromSource::DoExecute(NTabletFlatExecutor::TTransactionContext& txc,
         }
         dbWrapper.WriteCounter(TColumnEngineForLogs::LAST_PORTION, *lastPortionPtr);
     }
-    auto schemaPtr = index.GetVersionedIndex().GetLastSchema();
     THashMap<TString, THashSet<NBlobCache::TUnifiedBlobId>> sharedBlobIds;
     for (auto&& i : PortionsByPathId) {
         for (auto&& p : i.second.GetPortions()) {
-            p.SaveToDatabase(dbWrapper, schemaPtr->GetIndexInfo().GetPKFirstColumnId(), false);
+            p.SaveToDatabase(dbWrapper, false);
         }
     }
     NIceDb::TNiceDb db(txc.DB);

Original file line number	Diff line number	Diff line change
`@@ -17,11 +17,10 @@ bool TTxDataFromSource::DoExecute(NTabletFlatExecutor::TTransactionContext& txc,`
`17`	`17`	`}`
`18`	`18`	`dbWrapper.WriteCounter(TColumnEngineForLogs::LAST_PORTION, *lastPortionPtr);`
`19`	`19`	`}`
`20`		`- auto schemaPtr = index.GetVersionedIndex().GetLastSchema();`
`21`	`20`	`THashMap<TString, THashSet<NBlobCache::TUnifiedBlobId>> sharedBlobIds;`
`22`	`21`	`for (auto&& i : PortionsByPathId) {`
`23`	`22`	`for (auto&& p : i.second.GetPortions()) {`
`24`		`- p.SaveToDatabase(dbWrapper, schemaPtr->GetIndexInfo().GetPKFirstColumnId(), false);`
	`23`	`+ p.SaveToDatabase(dbWrapper, false);`
`25`	`24`	`}`
`26`	`25`	`}`
`27`	`26`	`NIceDb::TNiceDb db(txc.DB);`