diff --git a/be/src/exec/tablet_sink.cpp b/be/src/exec/tablet_sink.cpp
index 30656e6fa2..59ff01646d 100644
--- a/be/src/exec/tablet_sink.cpp
+++ b/be/src/exec/tablet_sink.cpp
@@ -155,7 +155,6 @@ Status NodeChannel::close(RuntimeState* state) {
 }
 
 Status NodeChannel::_close(RuntimeState* state) {
-    RETURN_IF_ERROR(_wait_in_flight_packet());
     return _send_cur_batch(true);
 }