aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorIgor Makunin <igor.makunin@gmail.com>2022-03-01 13:35:42 +0300
committerIgor Makunin <igor.makunin@gmail.com>2022-03-01 13:35:42 +0300
commitd2d97d86f9d20726f108377593627c3fffd1cba8 (patch)
tree011197ab644373d1783dc59d4874b4e4b6870c77
parentb28a1ffdc9e78b9fe33508de65a2b31d903df932 (diff)
downloadydb-d2d97d86f9d20726f108377593627c3fffd1cba8.tar.gz
KIKIMR-14436: log error in case of fallback
ref:4508354b56293e00ffbfb7289cb59cbb0d564e05
-rw-r--r--ydb/core/kqp/kqp_worker_actor.cpp7
1 files changed, 4 insertions, 3 deletions
diff --git a/ydb/core/kqp/kqp_worker_actor.cpp b/ydb/core/kqp/kqp_worker_actor.cpp
index 1b27348e64..b7f74609f2 100644
--- a/ydb/core/kqp/kqp_worker_actor.cpp
+++ b/ydb/core/kqp/kqp_worker_actor.cpp
@@ -362,9 +362,6 @@ public:
auto& queryRequest = QueryState->Request;
if (fallbackToOldEngine) {
- LOG_DEBUG_S(ctx, NKikimrServices::KQP_WORKER, "OldEngine fallback request, proxyRequestId: "
- << QueryState->ProxyRequestId);
-
QueryState->ForceNewEngineState.ForcedNewEngine = false;
QueryState->OldEngineFallback = true;
}
@@ -593,6 +590,10 @@ public:
GetServiceCounters(AppData()->Counters, "kqp")->GetCounter("Requests/OldEngineFallback", true)->Inc();
+ LOG_ERROR_S(ctx, NKikimrServices::KQP_WORKER, "OldEngine fallback request"
+ << ", satus: " << Ydb::StatusIds::StatusCode_Name(status)
+ << ", issues: " << QueryState->QueryResult.Issues().ToString());
+
NCpuTime::TCpuTimer timer;
HandleQueryRequest(timer, true, ctx);
return;