diff options
author | mrlolthe1st <mrlolthe1st@yandex-team.com> | 2023-06-30 12:04:40 +0300 |
---|---|---|
committer | mrlolthe1st <mrlolthe1st@yandex-team.com> | 2023-06-30 12:04:40 +0300 |
commit | 24a6b2a35f177fe289cf57dc0119726a3108af7a (patch) | |
tree | c26cb9e0514d46c1ff58af705725554024308560 | |
parent | 45e2f15452d511b50016d579cae57234574b437c (diff) | |
download | ydb-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.cpp | 3 |
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; |