diff options
| author | Александр Новожилов <mrlolthe1st@ydb.tech> | 2025-05-27 18:02:06 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-05-27 15:02:06 +0000 |
| commit | 26726f2e4840fc48e361668d59cbfa4c6060e170 (patch) | |
| tree | d06304cf48dea91a8ca6ae936d7999ef4f229f65 | |
| parent | 8fa236de315950d6bf971e9f32618a5cda4b58e8 (diff) | |
| download | ydb-26726f2e4840fc48e361668d59cbfa4c6060e170.tar.gz | |
More RPC reader retries (#18904)
| -rw-r--r-- | ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp | 5 |
1 files changed, 4 insertions, 1 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 c571cad288d..623ae1b61b6 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 @@ -274,7 +274,10 @@ private: // RPC reader fallback to YT fallback = true; rpcReaderFalledBack = true; - } else if (line.Contains("Attachments stream write timed out") || line.Contains("No alive peers found")) { + } else if (rpcReaderFalledBack && (line.Contains("Attachments stream write timed out") + || line.Contains("No alive peers found") || line.Contains("Connection reset by peer") + || line.Contains("Connection timed out"))) + { // RPC reader DQ retry retry = true; } else if (line.Contains("Transaction") && line.Contains("aborted")) { |