aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoraozeritsky <aozeritsky@yandex-team.ru>2022-04-28 15:33:34 +0300
committeraozeritsky <aozeritsky@yandex-team.ru>2022-04-28 15:33:34 +0300
commit9637c4588b8357e2ddb7cd33883a5294f19306d0 (patch)
tree8312b900c5bbf8cf80d446ad6c042b613d5ed642
parentd6f28fc58bb01259c2e99e418ef4b234f8bacebd (diff)
downloadydb-9637c4588b8357e2ddb7cd33883a5294f19306d0.tar.gz
Add Fallback system counter
ref:52a552773546d0f8f6b60ace8cf0734b6bae229d
-rw-r--r--ydb/library/yql/core/facade/yql_facade.cpp10
-rw-r--r--ydb/library/yql/core/facade/yql_facade.h1
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