diff options
| author | DMokhnatkin <dmitriy.mokhnatkin@gmail.com> | 2022-06-09 18:00:00 +0300 |
|---|---|---|
| committer | DMokhnatkin <dmitriy.mokhnatkin@gmail.com> | 2022-06-09 18:00:00 +0300 |
| commit | 0cfac1cb0d218fe93b0417b0663a9a876fa71e67 (patch) | |
| tree | d64c416854e93188bb4ed68cdeb8818d61329885 | |
| parent | d5e8eb3e8399704deab119214d49e85fc5ab73fe (diff) | |
| download | ydb-0cfac1cb0d218fe93b0417b0663a9a876fa71e67.tar.gz | |
YQL-14656: fix null response handling
ref:02980817e7c8dca1ecb0b38362c86aba72d99c1b
| -rw-r--r-- | ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.cpp b/ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.cpp index 21b0d44907..9030e75ced 100644 --- a/ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.cpp +++ b/ydb/library/yql/providers/solomon/async_io/dq_solomon_write_actor.cpp @@ -61,6 +61,11 @@ const ui64 MaxRequestsInflight = 3; auto RetryPolicy = NYql::NDq::THttpSenderRetryPolicy::GetExponentialBackoffPolicy( [](const NHttp::TEvHttpProxy::TEvHttpIncomingResponse* resp){ + if (!resp || !resp->Response) { + // Connection wasn't established. Should retry. + return ERetryErrorClass::ShortRetry; + } + if (resp->Response->Status == "401") { return ERetryErrorClass::NoRetry; } |