aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoraozeritsky <aozeritsky@yandex-team.ru>2022-04-12 21:52:00 +0300
committeraozeritsky <aozeritsky@yandex-team.ru>2022-04-12 21:52:00 +0300
commitc7d63f15485bbd5f09d3d85d40d7172768c5a63f (patch)
treeb4d9a6c3af5c5312b89d6901ec67ac501e596c4d
parent26fffc7fdd4e9d77ecf2d1216701a725bac9aa07 (diff)
downloadydb-c7d63f15485bbd5f09d3d85d40d7172768c5a63f.tar.gz
YQL-13675: Rename retry counter
ref:455c58a17a88a5e686df8fc165ffa6415914b7fa
-rw-r--r--ydb/library/yql/providers/dq/service/grpc_service.cpp7
1 files changed, 4 insertions, 3 deletions
diff --git a/ydb/library/yql/providers/dq/service/grpc_service.cpp b/ydb/library/yql/providers/dq/service/grpc_service.cpp
index b10537591c..824c74fa60 100644
--- a/ydb/library/yql/providers/dq/service/grpc_service.cpp
+++ b/ydb/library/yql/providers/dq/service/grpc_service.cpp
@@ -59,6 +59,7 @@ namespace NYql::NDqs {
class TServiceProxyActor: public TSynchronizableRichActor<TServiceProxyActor<RequestType, ResponseType>> {
public:
static constexpr char ActorName[] = "SERVICE_PROXY";
+ static constexpr char RetryName[] = "OperationRetry";
explicit TServiceProxyActor(
NGrpc::IRequestContextBase* ctx,
@@ -69,7 +70,7 @@ namespace NYql::NDqs {
, Counters(counters)
, ServiceProxyActorCounters(counters->GetSubgroup("component", "ServiceProxyActor"))
, ClientDisconnectedCounter(ServiceProxyActorCounters->GetCounter("ClientDisconnected", /*derivative=*/ true))
- , RetryCounter(ServiceProxyActorCounters->GetCounter("Retry", /*derivative=*/ true))
+ , RetryCounter(ServiceProxyActorCounters->GetCounter(RetryName, /*derivative=*/ true))
, FallbackCounter(ServiceProxyActorCounters->GetCounter("Fallback", /*derivative=*/ true))
, ErrorCounter(ServiceProxyActorCounters->GetCounter("UnrecoverableError", /*derivative=*/ true))
, Request(dynamic_cast<const RequestType*>(ctx->GetRequest()))
@@ -183,10 +184,10 @@ namespace NYql::NDqs {
YQL_LOG(DEBUG) << "TServiceProxyActor::OnReturnResult " << ev->Get()->Record.GetMetric().size();
QueryStat.AddCounters(ev->Get()->Record);
if (ev->Get()->Record.GetIssues().size() > 0 && ev->Get()->Record.GetRetriable() && Retry < MaxRetries) {
- QueryStat.AddCounter("Retry", TDuration::MilliSeconds(0));
+ QueryStat.AddCounter(RetryName, TDuration::MilliSeconds(0));
NYql::TIssues issues;
NYql::IssuesFromMessage(ev->Get()->Record.GetIssues(), issues);
- YQL_LOG(WARN) << "Retry " << Retry << " Issues: " << issues.ToString();
+ YQL_LOG(WARN) << RetryName << " " << Retry << " Issues: " << issues.ToString();
DoRetry();
} else {
if (ev->Get()->Record.GetIssues().size() > 0) {