aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorwhcrc <whcrc@ydb.tech>2022-08-01 14:35:41 +0300
committerwhcrc <whcrc@ydb.tech>2022-08-01 14:35:41 +0300
commit08d1f2d898304568d5738bba8943ffa981539704 (patch)
tree10431de8503ece97ff077e0402d3ae91d82e9725
parent0ae3ab76a37cd9766a4bc1c402021ddfda25c163 (diff)
downloadydb-08d1f2d898304568d5738bba8943ffa981539704.tar.gz
fix retries on dq failure
-rw-r--r--ydb/library/yql/providers/dq/actors/executer_actor.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/library/yql/providers/dq/actors/executer_actor.cpp b/ydb/library/yql/providers/dq/actors/executer_actor.cpp
index b271f8d37f..e55ff410f7 100644
--- a/ydb/library/yql/providers/dq/actors/executer_actor.cpp
+++ b/ydb/library/yql/providers/dq/actors/executer_actor.cpp
@@ -272,7 +272,7 @@ private:
AddCounters(ev->Get()->Record);
bool retriable = ev->Get()->Record.GetDeprecatedRetriable();
// while we're investigating YQL-15117, we want to be sure that any failure leads to the fallback (except explicitly retriable ones)
- bool fallback = (!retriable || ev->Get()->Record.GetDeprecatedNeedFallback());
+ bool fallback = true;
auto status = ev->Get()->Record.GetStatusCode();
if (status == NYql::NDqProto::StatusIds::UNSPECIFIED) {
status = NYql::NDqProto::StatusIds::INTERNAL_ERROR;