diff --git a/be/src/exec/operator/materialization_opertor.cpp b/be/src/exec/operator/materialization_opertor.cpp
index 17ea2664e0ff01..f2349476e4f4df 100644
--- a/be/src/exec/operator/materialization_opertor.cpp
+++ b/be/src/exec/operator/materialization_opertor.cpp
@@ -424,6 +424,12 @@ Status MaterializationOperator::push(RuntimeState* state, Block* in_block, bool
                         " 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();
         }