This is an automated email from the ASF dual-hosted git repository.
gavinchou pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 74f48b6fadd branch-3.0: [opt](s3filewriter) Optimize exception
handling when put object #43809 (#43964)
74f48b6fadd is described below
commit 74f48b6fadde4910b691263bab337d9071401ee6
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Nov 14 20:02:44 2024 +0800
branch-3.0: [opt](s3filewriter) Optimize exception handling when put object
#43809 (#43964)
Cherry-picked from #43809
Co-authored-by: Gavin Chou <[email protected]>
---
be/src/io/fs/s3_file_writer.cpp | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
diff --git a/be/src/io/fs/s3_file_writer.cpp b/be/src/io/fs/s3_file_writer.cpp
index e40b9e171eb..7a06ce22074 100644
--- a/be/src/io/fs/s3_file_writer.cpp
+++ b/be/src/io/fs/s3_file_writer.cpp
@@ -379,7 +379,14 @@ Status
S3FileWriter::_set_upload_to_remote_less_than_buffer_size() {
}
void S3FileWriter::_put_object(UploadFileBuffer& buf) {
- DCHECK(state() != State::CLOSED) << fmt::format("state is {}", state());
+ if (state() == State::CLOSED) {
+ DCHECK(state() != State::CLOSED)
+ << "state=" << (int)state() << " path=" <<
_obj_storage_path_opts.path.native();
+ LOG_WARNING("failed to put object because file closed, file path {}",
+ _obj_storage_path_opts.path.native());
+ buf.set_status(Status::InternalError<false>("try to put closed file"));
+ return;
+ }
const auto& client = _obj_client->get();
if (nullptr == client) {
buf.set_status(Status::InternalError<false>("invalid obj storage
client"));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
