aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authormrlolthe1st <mrlolthe1st@yandex-team.com>2023-06-30 12:04:40 +0300
committermrlolthe1st <mrlolthe1st@yandex-team.com>2023-06-30 12:04:40 +0300
commit24a6b2a35f177fe289cf57dc0119726a3108af7a (patch)
treec26cb9e0514d46c1ff58af705725554024308560
parent45e2f15452d511b50016d579cae57234574b437c (diff)
downloadydb-24a6b2a35f177fe289cf57dc0119726a3108af7a.tar.gz
YQL-16143: Add RPC reader timeout setting, handle exception in proper way
YQL-16143: Add RPC reader timeout setting, handle exception in proper way
-rw-r--r--ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp3
1 files changed, 3 insertions, 0 deletions
diff --git a/ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp b/ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp
index b10fc00559a..cc15144f14e 100644
--- a/ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp
+++ b/ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp
@@ -111,6 +111,9 @@ private:
} else if (line.Contains("No such transaction")) {
// YQL-15542
fallback = true;
+ } else if (line.Contains("(NYT::TErrorException) Request timed out")) {
+ // RPC reader fallback to YT
+ fallback = true;
} else if (line.Contains("Transaction") && line.Contains("aborted")) {
// YQL-15542
fallback = true;