diff options
author | aozeritsky <aozeritsky@yandex-team.ru> | 2022-04-28 15:33:34 +0300 |
---|---|---|
committer | aozeritsky <aozeritsky@yandex-team.ru> | 2022-04-28 15:33:34 +0300 |
commit | 9637c4588b8357e2ddb7cd33883a5294f19306d0 (patch) | |
tree | 8312b900c5bbf8cf80d446ad6c042b613d5ed642 | |
parent | d6f28fc58bb01259c2e99e418ef4b234f8bacebd (diff) | |
download | ydb-9637c4588b8357e2ddb7cd33883a5294f19306d0.tar.gz |
Add Fallback system counter
ref:52a552773546d0f8f6b60ace8cf0734b6bae229d
-rw-r--r-- | ydb/library/yql/core/facade/yql_facade.cpp | 10 | ||||
-rw-r--r-- | ydb/library/yql/core/facade/yql_facade.h | 1 |
2 files changed, 11 insertions, 0 deletions
diff --git a/ydb/library/yql/core/facade/yql_facade.cpp b/ydb/library/yql/core/facade/yql_facade.cpp index 77b71e69826..035975464f5 100644 --- a/ydb/library/yql/core/facade/yql_facade.cpp +++ b/ydb/library/yql/core/facade/yql_facade.cpp @@ -993,6 +993,7 @@ TFuture<IGraphTransformer::TStatus> TProgram::AsyncTransformWithFallback(bool ap ExprCtx_->IssueManager.AddIssues({warning}); } + FallbackCounter ++; // don't execute recapture again ExprCtx_->Step.Done(TExprStep::Recapture); return AsyncTransformWithFallback(false); @@ -1162,6 +1163,15 @@ TMaybe<TString> TProgram::GetStatistics(bool totalOnly) { writer.OnKeyedItem("count"); writer.OnInt64Scalar(rusage.MajorPageFaults); writer.OnEndMap(); + + if (FallbackCounter) { + writer.OnKeyedItem("Fallback"); + writer.OnBeginMap(); + writer.OnKeyedItem("count"); + writer.OnInt64Scalar(FallbackCounter); + writer.OnEndMap(); + } + writer.OnEndMap(); // system // Footer diff --git a/ydb/library/yql/core/facade/yql_facade.h b/ydb/library/yql/core/facade/yql_facade.h index 586747551f1..4ba75c5ba78 100644 --- a/ydb/library/yql/core/facade/yql_facade.h +++ b/ydb/library/yql/core/facade/yql_facade.h @@ -386,6 +386,7 @@ private: TOperationProgressWriter ProgressWriter_ = [](const TOperationProgress&) {}; TString ExtractedQueryParametersMetadataYson_; const bool EnableRangeComputeFor_; + i64 FallbackCounter = 0; }; } // namspace NYql |