fix

zjw1111 · zjw1111 · commit 27b757b43f49 · 2026-02-02T10:27:35.000+08:00
diff --git a/src/paimon/format/avro/avro_output_stream_impl.cpp b/src/paimon/format/avro/avro_output_stream_impl.cpp
@@ -71,7 +71,10 @@ void AvroOutputStreamImpl::FlushBuffer() {
             fmt::format("write failed, expected length: {}, actual write length: {}", length,
                         write_len.value()));
     }
-    out_->Flush();
+    Status status = out_->Flush();
+    if (!status.ok()) {
+        throw std::runtime_error("flush failed, status: " + status.ToString());
+    }
     next_ = buffer_;
     available_ = buffer_size_;
 }

Original file line number	Diff line number	Diff line change
`@@ -71,7 +71,10 @@ void AvroOutputStreamImpl::FlushBuffer() {`
`71`	`71`	`fmt::format("write failed, expected length: {}, actual write length: {}", length,`
`72`	`72`	`write_len.value()));`
`73`	`73`	`}`
`74`		`- out_->Flush();`
	`74`	`+ Status status = out_->Flush();`
	`75`	`+ if (!status.ok()) {`
	`76`	`+ throw std::runtime_error("flush failed, status: " + status.ToString());`
	`77`	`+ }`
`75`	`78`	`next_ = buffer_;`
`76`	`79`	`available_ = buffer_size_;`
`77`	`80`	`}`