diff options
| author | stanislav_shchetinin <st-shchetinin@ydb.tech> | 2024-08-29 23:55:21 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-08-29 20:55:21 +0000 |
| commit | ea7bd233582499e7cffe287783572d4d0393155a (patch) | |
| tree | cf53a8d911cb28f6312836835436169cbeff817e | |
| parent | df3f77eb7ccdd6dbbaff6c41b38cb1c7045697bc (diff) | |
| download | ydb-ea7bd233582499e7cffe287783572d4d0393155a.tar.gz | |
$$$[KQP] Status processing added$$$ (#8502)
| -rw-r--r-- | ydb/core/kqp/gateway/actors/analyze_actor.cpp | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/ydb/core/kqp/gateway/actors/analyze_actor.cpp b/ydb/core/kqp/gateway/actors/analyze_actor.cpp index e9384a78e8..326d39a440 100644 --- a/ydb/core/kqp/gateway/actors/analyze_actor.cpp +++ b/ydb/core/kqp/gateway/actors/analyze_actor.cpp @@ -46,6 +46,12 @@ void TAnalyzeActor::Handle(NStat::TEvStatistics::TEvAnalyzeResponse::TPtr& ev, c const auto& record = ev->Get()->Record; const TString operationId = record.GetOperationId(); + const auto status = record.GetStatus(); + + if (status != NKikimrStat::TEvAnalyzeResponse::STATUS_SUCCESS) { + ALOG_CRIT(NKikimrServices::KQP_GATEWAY, + "TAnalyzeActor, TEvAnalyzeResponse has status=" << status); + } if (operationId != OperationId) { ALOG_CRIT(NKikimrServices::KQP_GATEWAY, |