diff --git a/be/src/pipeline/exec/materialization_opertor.cpp b/be/src/pipeline/exec/materialization_opertor.cpp
index 1e3c34aabe89e3..e4a12c202ba935 100644
--- a/be/src/pipeline/exec/materialization_opertor.cpp
+++ b/be/src/pipeline/exec/materialization_opertor.cpp
@@ -428,6 +428,12 @@ Status MaterializationOperator::push(RuntimeState* state, vectorized::Block* in_
                         " target_backend_id:" + std::to_string(backend_id);
                 return Status::InternalError(error_text);
             }
+            if (rpc_struct.response.status().status_code() != 0) {
+                Status st = Status::create(rpc_struct.response.status());
+                st.append(fmt::format(", Backend:{}, Materialization Sink node id:{}", backend_id,
+                                      node_id()));
+                return st;
+            }
             rpc_struct.cntl->Reset();
         }