diff options
| author | rraed <[email protected]> | 2025-06-18 19:42:49 +0300 |
|---|---|---|
| committer | rraed <[email protected]> | 2025-06-18 20:05:23 +0300 |
| commit | 5ff916b9419f41c5078bb194b605bfe8519b0aed (patch) | |
| tree | 049c757e59955882db4b6bf358aee7d86ea38814 | |
| parent | 47a80ed902e4e755477cd5b8a14a4f10c06938f9 (diff) | |
Fix YT parallel table writer hang after Abort
commit_hash:a5ac90256dbdaeb37858aeacaf24931ed10c8d4d
| -rw-r--r-- | yt/cpp/mapreduce/client/retryful_writer.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/client/retryful_writer.cpp b/yt/cpp/mapreduce/client/retryful_writer.cpp index d68f8f4d3d3..16ea38a0559 100644 --- a/yt/cpp/mapreduce/client/retryful_writer.cpp +++ b/yt/cpp/mapreduce/client/retryful_writer.cpp @@ -21,6 +21,10 @@ namespace NYT { TRetryfulWriter::~TRetryfulWriter() { NDetail::FinishOrDie(this, AutoFinish_, "TRetryfulWriter"); + if (WriterState_ == Ok) { + Y_ABORT_IF(AutoFinish_); // if AutoFinish_, FinishOrDie would have called Finish + Abort(); + } } void TRetryfulWriter::CheckWriterState() |