Fix YT parallel table writer hang after Abort

raid-7 · raid-7 · commit 5ff916b9419f · 2025-06-18T20:05:23.000+03:00
commit_hash:a5ac90256dbdaeb37858aeacaf24931ed10c8d4d
diff --git 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()

Original file line number	Diff line number	Diff line change
`@@ -21,6 +21,10 @@ namespace NYT {`
`21`	`21`	`TRetryfulWriter::~TRetryfulWriter()`
`22`	`22`	`{`
`23`	`23`	`NDetail::FinishOrDie(this, AutoFinish_, "TRetryfulWriter");`
	`24`	`+ if (WriterState_ == Ok) {`
	`25`	`+ Y_ABORT_IF(AutoFinish_); // if AutoFinish_, FinishOrDie would have called Finish`
	`26`	`+ Abort();`
	`27`	`+ }`
`24`	`28`	`}`
`25`	`29`
`26`	`30`	`void TRetryfulWriter::CheckWriterState()`