@@ -159,54 +159,6 @@ Y_UNIT_TEST_SUITE(KqpOlapTiering) {
159159 UNIT_ASSERT_VALUES_UNEQUAL (result.GetStatus (), NYdb::EStatus::SUCCESS);
160160 }
161161 }
162-
163- Y_UNIT_TEST (InitSettings) {
164- auto csController = NYDBTest::TControllers::RegisterCSControllerGuard<NOlap::TWaitCompactionController>();
165- csController->SetSkipSpecialCheckForEvict (true );
166-
167- TKikimrSettings runnerSettings;
168- runnerSettings.WithSampleTables = false ;
169- TTestHelper testHelper (runnerSettings);
170- TLocalHelper localHelper (testHelper.GetKikimr ());
171- NYdb::NTable::TTableClient tableClient = testHelper.GetKikimr ().GetTableClient ();
172- Tests::NCommon::TLoggerInit (testHelper.GetKikimr ()).Initialize ();
173-
174- localHelper.CreateTestOlapTable ();
175- {
176- const TString query = R"( ALTER TABLE `/Root/olapTable` SET TTL Interval("P0D") ON timestamp)" ;
177- auto result = testHelper.GetSession ().ExecuteSchemeQuery (query).GetValueSync ();
178- UNIT_ASSERT_VALUES_UNEQUAL (result.GetStatus (), NYdb::EStatus::SUCCESS);
179- }
180- {
181- const TString query = R"( ALTER TABLE `/Root/olapTable` SET RESET TTL Interval("P0D") ON timestamp)" ;
182- auto result = testHelper.GetSession ().ExecuteSchemeQuery (query).GetValueSync ();
183- UNIT_ASSERT_VALUES_UNEQUAL (result.GetStatus (), NYdb::EStatus::SUCCESS);
184- }
185-
186- for (ui64 i = 0 ; i < 100 ; ++i) {
187- WriteTestData (testHelper.GetKikimr (), " /Root/olapStore/olapTable" , 0 , i * 10000 , 1000 );
188- }
189-
190- csController->WaitCompactions (TDuration::Seconds (5 ));
191- csController->WaitActualization (TDuration::Seconds (5 ));
192-
193- {
194- auto selectQuery = TString (R"(
195- SELECT
196- TierName, SUM(ColumnRawBytes) As RawBytes
197- FROM `/Root/olapStore/olapTable/.sys/primary_index_portion_stats`
198- WHERE Activity == 1
199- GROUP BY TierName
200- )" );
201-
202- auto rows = ExecuteScanQuery (tableClient, selectQuery);
203- UNIT_ASSERT_VALUES_EQUAL (rows.size (), 1 );
204- UNIT_ASSERT_VALUES_EQUAL (GetUtf8 (rows[0 ].at (" TierName" )), " __DEFAULT" );
205- UNIT_ASSERT_VALUES_EQUAL_C (GetUint64 (rows[0 ].at (" RawBytes" )), columnRawBytes,
206- TStringBuilder () << " RawBytes changed after resetting tiering: before=" << columnRawBytes
207- << " after=" << GetUint64 (rows[0 ].at (" RawBytes" )));
208- }
209- }
210162}
211163
212164} // namespace NKikimr::NKqp
0 commit comments