diff options
| author | a-romanov <[email protected]> | 2023-08-16 15:24:07 +0300 |
|---|---|---|
| committer | a-romanov <[email protected]> | 2023-08-16 16:47:06 +0300 |
| commit | 5b31dd67e2acdaca5aec0404edbe949ca9c1d544 (patch) | |
| tree | 5e06b349a84c171d870d7973df12bbb853e70b2b | |
| parent | 5c2405ab8c1e8cf1ba22505d529bdc0d96ecf675 (diff) | |
YQL-16314 Pull may re-enter execution in case with download files.
| -rw-r--r-- | ydb/library/yql/providers/yt/provider/yql_yt_datasink_exec.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/library/yql/providers/yt/provider/yql_yt_datasink_exec.cpp b/ydb/library/yql/providers/yt/provider/yql_yt_datasink_exec.cpp index a794c783fa6..da4a7def2ea 100644 --- a/ydb/library/yql/providers/yt/provider/yql_yt_datasink_exec.cpp +++ b/ydb/library/yql/providers/yt/provider/yql_yt_datasink_exec.cpp @@ -555,7 +555,7 @@ private: if (publicId) { if (State_->HybridInFlightOprations.empty()) State_->HybridStartTime = NMonotonic::TMonotonic::Now(); - YQL_ENSURE(State_->HybridInFlightOprations.emplace(*publicId).second, "Operation " << *publicId << " already started."); + State_->HybridInFlightOprations.emplace(*publicId); } return RunDqWrite(input, ctx, tmpTable); } else { |