diff options
| author | Roman Udovichenko <rvu@ydb.tech> | 2025-04-16 17:57:57 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-04-16 17:57:57 +0300 |
| commit | 979cba78b76f7a0f9ec3ef7c3d18e93b7bd201a8 (patch) | |
| tree | 08e8d6db2683c3a4a253e2e29d69dde308d22e48 | |
| parent | e820a40967640882aaf3e110127488bc2654e81a (diff) | |
| download | ydb-979cba78b76f7a0f9ec3ef7c3d18e93b7bd201a8.tar.gz | |
Use retryable code for error when DQ leader is changed (#17288)
| -rw-r--r-- | ydb/library/yql/providers/dq/global_worker_manager/global_worker_manager.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/library/yql/providers/dq/global_worker_manager/global_worker_manager.cpp b/ydb/library/yql/providers/dq/global_worker_manager/global_worker_manager.cpp index f84c1bf1e7a..72149617c66 100644 --- a/ydb/library/yql/providers/dq/global_worker_manager/global_worker_manager.cpp +++ b/ydb/library/yql/providers/dq/global_worker_manager/global_worker_manager.cpp @@ -671,7 +671,7 @@ private: Send(value.ActorId, new TEvents::TEvPoison()); } for (const auto sender : Scheduler->Cleanup()) { - Send(sender, new TEvAllocateWorkersResponse("StartFollower", NYql::NDqProto::StatusIds::UNSPECIFIED)); + Send(sender, new TEvAllocateWorkersResponse("Worker reallocation is required because of DQ leader change", NYql::NDqProto::StatusIds::UNAVAILABLE)); } AllocatedResources.clear(); for (auto& [k, v] : LiteralQueries) { |