Skip to content

Commit

Permalink
additional logging (ydb-platform#4195)
Browse files Browse the repository at this point in the history
  • Loading branch information
ivanmorozov333 authored Apr 30, 2024
1 parent 65ed5d1 commit 22f57bd
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions ydb/core/tx/tiering/ut/ut_tiers.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -927,8 +927,9 @@ Y_UNIT_TEST_SUITE(ColumnShardTiers) {
return false;
};
runtime.SetEventFilter(captureEvents);

Cerr << "START data loading..." << Endl;
lHelper.SendDataViaActorSystem("/Root/olapStore/olapTable", batch);
Cerr << "Data loading FINISHED" << Endl;

{
TVector<THashMap<TString, NYdb::TValue>> result;
Expand All @@ -941,6 +942,7 @@ Y_UNIT_TEST_SUITE(ColumnShardTiers) {
}
const ui32 reduceStepsCount = 1;
for (ui32 i = 0; i < reduceStepsCount; ++i) {
Cerr << "START data cleaning..." << Endl;
runtime.AdvanceCurrentTime(TDuration::Seconds(numRecords * (i + 1) / reduceStepsCount + 500000));
const ui64 purposeSize = 800000000.0 * (1 - 1.0 * (i + 1) / reduceStepsCount);
const ui64 purposeRecords = numRecords * (1 - 1.0 * (i + 1) / reduceStepsCount);
Expand All @@ -950,7 +952,7 @@ Y_UNIT_TEST_SUITE(ColumnShardTiers) {
runtime.AdvanceCurrentTime(TDuration::Minutes(6));
runtime.SimulateSleep(TDuration::Seconds(1));
}
Cerr << bsCollector.GetChannelSize(2) << "/" << purposeSize << Endl;
Cerr << "CLEANED: " << bsCollector.GetChannelSize(2) << "/" << purposeSize << Endl;

TVector<THashMap<TString, NYdb::TValue>> result;
lHelper.StartScanRequest("SELECT MIN(timestamp) as b, COUNT(*) as c FROM `/Root/olapStore/olapTable`", true, &result);
Expand Down

0 comments on commit 22f57bd

Please sign in to comment.