fix

ivanmorozov333 · ivanmorozov333 · commit 1c1b3824e097 · 2024-09-19T20:50:36.000+03:00
diff --git a/ydb/core/tx/columnshard/operations/write.cpp b/ydb/core/tx/columnshard/operations/write.cpp
@@ -35,7 +35,7 @@ void TWriteOperation::Start(TColumnShard& owner, const ui64 tableId, const NEvWr
             NEvWrite::TWriteData(writeMeta, data, owner.TablesManager.GetPrimaryIndex()->GetReplaceKey(),
                 owner.StoragesManager->GetInsertOperator()->StartWritingAction(NOlap::NBlobOperations::EConsumer::WRITING_OPERATOR)),
             schema, owner.GetLastTxSnapshot(), owner.Counters.GetCSCounters().WritingCounters);
-    NConveyor::TCompServiceOperator::SendTaskToExecute(task);
+    NConveyor::TInsertServiceOperator::AsyncTaskToExecute(task);
 
     Status = EOperationStatus::Started;
 }

Original file line number	Diff line number	Diff line change
`@@ -35,7 +35,7 @@ void TWriteOperation::Start(TColumnShard& owner, const ui64 tableId, const NEvWr`
`35`	`35`	`NEvWrite::TWriteData(writeMeta, data, owner.TablesManager.GetPrimaryIndex()->GetReplaceKey(),`
`36`	`36`	`owner.StoragesManager->GetInsertOperator()->StartWritingAction(NOlap::NBlobOperations::EConsumer::WRITING_OPERATOR)),`
`37`	`37`	`schema, owner.GetLastTxSnapshot(), owner.Counters.GetCSCounters().WritingCounters);`
`38`		`- NConveyor::TCompServiceOperator::SendTaskToExecute(task);`
	`38`	`+ NConveyor::TInsertServiceOperator::AsyncTaskToExecute(task);`
`39`	`39`
`40`	`40`	`Status = EOperationStatus::Started;`
`41`	`41`	`}`