Merge 3bf1d31 into 7672737

MBkkt · web-flow · commit 6d7c5cd98211 · 2024-11-05T08:51:22.000Z
diff --git a/ydb/core/tx/datashard/build_index.cpp b/ydb/core/tx/datashard/build_index.cpp
@@ -626,7 +626,7 @@ void TDataShard::HandleSafe(TEvDataShard::TEvBuildIndexCreateRequest::TPtr& ev,
                                                        record.GetColumnBuildSettings(),
                                                        userTable,
                                                        limits),
-                                  ev->Cookie,
+                                  0,
                                   scanOpts);
 
     TScanRecord recCard = {scanId, seqNo};
diff --git a/ydb/core/tx/datashard/local_kmeans.cpp b/ydb/core/tx/datashard/local_kmeans.cpp
@@ -663,7 +663,7 @@ void TDataShard::HandleSafe(TEvDataShard::TEvLocalKMeansRequest::TPtr& ev, const
     TScanOptions scanOpts;
     scanOpts.SetSnapshotRowVersion(rowVersion);
     scanOpts.SetResourceBroker("build_index", 10); // TODO(mbkkt) Should be different group?
-    const auto scanId = QueueScan(userTable.LocalTid, std::move(scan), ev->Cookie, scanOpts);
+    const auto scanId = QueueScan(userTable.LocalTid, std::move(scan), 0, scanOpts);
     TScanRecord recCard = {scanId, seqNo};
     ScanManager.Set(id, recCard);
 }
diff --git a/ydb/core/tx/datashard/reshuffle_kmeans.cpp b/ydb/core/tx/datashard/reshuffle_kmeans.cpp
@@ -460,7 +460,7 @@ void TDataShard::HandleSafe(TEvDataShard::TEvReshuffleKMeansRequest::TPtr& ev, c
     TScanOptions scanOpts;
     scanOpts.SetSnapshotRowVersion(rowVersion);
     scanOpts.SetResourceBroker("build_index", 10); // TODO(mbkkt) Should be different group?
-    const auto scanId = QueueScan(userTable.LocalTid, std::move(scan), ev->Cookie, scanOpts);
+    const auto scanId = QueueScan(userTable.LocalTid, std::move(scan), 0, scanOpts);
     TScanRecord recCard = {scanId, seqNo};
     ScanManager.Set(id, recCard);
 }
diff --git a/ydb/core/tx/datashard/sample_k.cpp b/ydb/core/tx/datashard/sample_k.cpp
@@ -351,7 +351,7 @@ void TDataShard::HandleSafe(TEvDataShard::TEvSampleKRequest::TPtr& ev, const TAc
                                       record.GetMaxProbability(),
                                       record.GetColumns(),
                                       userTable),
-                                  ev->Cookie,
+                                  0,
                                   scanOpts);
 
     TScanRecord recCard = {scanId, seqNo};

Original file line number	Diff line number	Diff line change
`@@ -663,7 +663,7 @@ void TDataShard::HandleSafe(TEvDataShard::TEvLocalKMeansRequest::TPtr& ev, const`
`663`	`663`	`TScanOptions scanOpts;`
`664`	`664`	`scanOpts.SetSnapshotRowVersion(rowVersion);`
`665`	`665`	`scanOpts.SetResourceBroker("build_index", 10); // TODO(mbkkt) Should be different group?`
`666`		`- const auto scanId = QueueScan(userTable.LocalTid, std::move(scan), ev->Cookie, scanOpts);`
	`666`	`+ const auto scanId = QueueScan(userTable.LocalTid, std::move(scan), 0, scanOpts);`
`667`	`667`	`TScanRecord recCard = {scanId, seqNo};`
`668`	`668`	`ScanManager.Set(id, recCard);`
`669`	`669`	`}`
Original file line number	Diff line number	Diff line change
`@@ -460,7 +460,7 @@ void TDataShard::HandleSafe(TEvDataShard::TEvReshuffleKMeansRequest::TPtr& ev, c`
`460`	`460`	`TScanOptions scanOpts;`
`461`	`461`	`scanOpts.SetSnapshotRowVersion(rowVersion);`
`462`	`462`	`scanOpts.SetResourceBroker("build_index", 10); // TODO(mbkkt) Should be different group?`
`463`		`- const auto scanId = QueueScan(userTable.LocalTid, std::move(scan), ev->Cookie, scanOpts);`
	`463`	`+ const auto scanId = QueueScan(userTable.LocalTid, std::move(scan), 0, scanOpts);`
`464`	`464`	`TScanRecord recCard = {scanId, seqNo};`
`465`	`465`	`ScanManager.Set(id, recCard);`
`466`	`466`	`}`