@@ -288,7 +288,7 @@ Y_UNIT_TEST_SUITE(KqpOlapTiering) {
288
288
// auto selectQuery = TString(R"(
289
289
// SELECT MAX(timestamp) AS timestamp FROM `/Root/olapStore/olapTable`
290
290
// )");
291
- //
291
+ //
292
292
// auto rows = ExecuteScanQuery(tableClient, selectQuery);
293
293
// UNIT_ASSERT_VALUES_EQUAL(rows.size(), 1);
294
294
// UNIT_ASSERT_GT(GetTimestamp(rows[0].at(DEFAULT_COLUMN_NAME)), TInstant::Now() - TDuration::Days(100));
@@ -329,17 +329,20 @@ Y_UNIT_TEST_SUITE(KqpOlapTiering) {
329
329
auto & csController = tieringHelper.GetCsController ();
330
330
auto & olapHelper = tieringHelper.GetOlapHelper ();
331
331
auto & testHelper = tieringHelper.GetTestHelper ();
332
- NYdb::NTable::TTableClient tableClient = testHelper.GetKikimr ().GetTableClient ();
332
+ const auto & kikimr = testHelper.GetKikimr ();
333
+ NYdb::NTable::TTableClient tableClient = kikimr.GetTableClient ();
333
334
334
335
olapHelper.CreateTestOlapTable ();
336
+ const auto describeResult = kikimr.GetTestClient ().Describe (
337
+ kikimr.GetTestServer ().GetRuntime (), " Root/olapStore/olapTable" );
338
+ const auto tablePathId = NColumnShard::TSchemeShardLocalPathId::FromRawValue (describeResult.GetPathId ());
339
+
335
340
tieringHelper.WriteSampleData ();
336
341
csController->WaitCompactions (TDuration::Seconds (5 ));
337
342
THashSet<NColumnShard::TInternalPathId> pathsToLock;
338
343
for (const auto & [_, pathIdTranslator]: csController->GetActiveTablets ()) {
339
- for (size_t i = 0 ; i != 6 ; ++i) {
340
- if (auto internalPathId = pathIdTranslator->ResolveInternalPathId (NColumnShard::TSchemeShardLocalPathId::FromRawValue (i))) {
341
- pathsToLock.insert (*internalPathId);
342
- }
344
+ if (auto internalPathId = pathIdTranslator->ResolveInternalPathId (tablePathId)) {
345
+ pathsToLock.insert (*internalPathId);
343
346
}
344
347
};
345
348
@@ -412,13 +415,13 @@ Y_UNIT_TEST_SUITE(KqpOlapTiering) {
412
415
auto & putController = tieringHelper.GetCsController ();
413
416
auto & olapHelper = tieringHelper.GetOlapHelper ();
414
417
auto & testHelper = tieringHelper.GetTestHelper ();
415
-
416
-
418
+
419
+
417
420
olapHelper.CreateTestOlapTable ();
418
421
testHelper.CreateTier (" tier1" );
419
422
tieringHelper.WriteSampleData ();
420
423
putController->WaitCompactions (TDuration::Seconds (5 ));
421
-
424
+
422
425
putController->SetExternalStorageUnavailable (true );
423
426
testHelper.SetTiering (DEFAULT_TABLE_NAME,
424
427
DEFAULT_TIER_NAME,
0 commit comments