diff --git a/be/src/vec/sink/writer/vtablet_writer_v2.cpp b/be/src/vec/sink/writer/vtablet_writer_v2.cpp
index 96b03144487d818..850cc48b62363aa 100644
--- a/be/src/vec/sink/writer/vtablet_writer_v2.cpp
+++ b/be/src/vec/sink/writer/vtablet_writer_v2.cpp
@@ -525,7 +525,7 @@ Status VTabletWriterV2::close(Status exec_status) {
                 for (const auto& stream : streams->streams()) {
                     LOG(INFO) << "begin waiting stream close load_id=" << print_id(_load_id)
                               << ", stream_id=" << stream->stream_id();
-                    RETURN_IF_ERROR(stream->close_wait());
+                    DCHECK(stream->close_wait().ok());
                     LOG(INFO) << "end waiting stream close load_id=" << print_id(_load_id)
                               << ", stream_id=" << stream->stream_id();
                 }