diff options
| author | eivanov89 <eivanov89@ydb.tech> | 2022-09-28 17:29:02 +0300 |
|---|---|---|
| committer | eivanov89 <eivanov89@ydb.tech> | 2022-09-28 17:29:02 +0300 |
| commit | 6f14e4f0ab5f6a8cb5b54e014719fb3a5c470c98 (patch) | |
| tree | 3302960c8b40925e6b27f78f9ca76c53fb44e71a | |
| parent | c31acefb6d6c3f3f9fc27420eb5199f2ad7e79d5 (diff) | |
| download | ydb-6f14e4f0ab5f6a8cb5b54e014719fb3a5c470c98.tar.gz | |
PR from branch users/eivanov89/-iterator-load-actor
properly calculate number of ops
fix typo and notice logs
| -rw-r--r-- | ydb/core/tx/datashard/testload/test_load_read_iterator.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/ydb/core/tx/datashard/testload/test_load_read_iterator.cpp b/ydb/core/tx/datashard/testload/test_load_read_iterator.cpp index 8d771f3587d..4b57e426a3a 100644 --- a/ydb/core/tx/datashard/testload/test_load_read_iterator.cpp +++ b/ydb/core/tx/datashard/testload/test_load_read_iterator.cpp @@ -609,13 +609,13 @@ private: switch (State) { case EState::Upsert: { - LOG_DEBUG_S(ctx, NKikimrServices::DS_LOAD_TEST, "upsert actor# " << ev->Sender + LOG_NOTICE_S(ctx, NKikimrServices::DS_LOAD_TEST, "upsert actor# " << ev->Sender << " finished: " << msg->Report->ToString()); State = EState::FullScan; return Run(ctx); } case EState::FullScan: { - LOG_DEBUG_S(ctx, NKikimrServices::DS_LOAD_TEST, "fullscan actor# " << ev->Sender + LOG_NOTICE_S(ctx, NKikimrServices::DS_LOAD_TEST, "fullscan actor# " << ev->Sender << " with chunkSize# " << ChunkSizes[ChunkIndex] << " finished: " << msg->Report->ToString()); Errors += msg->Report->OperationsError; @@ -642,7 +642,7 @@ private: return StopWithError(ctx, TStringBuilder() << "TEvTestLoadFinished while in " << State); case EState::ReadHeadPoints: { Y_VERIFY(Inflight == 0); - LOG_DEBUG_S(ctx, NKikimrServices::DS_LOAD_TEST, "headread with inflight# " << Inflights[InflightIndex] + LOG_NOTICE_S(ctx, NKikimrServices::DS_LOAD_TEST, "headread with inflight# " << Inflights[InflightIndex] << " finished: " << msg->Report->ToString()); Errors += msg->Report->OperationsError; Oks += msg->Report->OperationsOK; @@ -733,7 +733,7 @@ private: auto response = std::make_unique<TEvDataShardLoad::TEvTestLoadFinished>(0); response->Report = TEvDataShardLoad::TLoadReport(); response->Report->Duration = delta; - response->Report->OperationsOK = Inflights[InflightIndex] * Config.GetRowCount(); + response->Report->OperationsOK = Inflights[InflightIndex] * ReadCount; response->Report->OperationsError = 0; TStringStream ss; @@ -795,7 +795,7 @@ private: } void StopWithError(const TActorContext& ctx, const TString& reason) { - LOG_WARN_S(ctx, NKikimrServices::DS_LOAD_TEST, "TKqpUpsertActorMultiSession# " << Tag + LOG_WARN_S(ctx, NKikimrServices::DS_LOAD_TEST, "ReadIteratorLoadScenario# " << Tag << " stopped with error: " << reason); ctx.Send(Parent, new TEvDataShardLoad::TEvTestLoadFinished(Tag, reason)); |