diff --git a/be/src/pipeline/exec/olap_table_sink_operator.h b/be/src/pipeline/exec/olap_table_sink_operator.h index 9330f9520e..762fee5982 100644 --- a/be/src/pipeline/exec/olap_table_sink_operator.h +++ b/be/src/pipeline/exec/olap_table_sink_operator.h @@ -39,7 +39,7 @@ public: OlapTableSinkOperator(OperatorBuilderBase* operator_builder, DataSink* sink) : DataSinkOperator(operator_builder, sink) {} - bool can_write() override { return true; } // TODO: need use mem_limit + bool can_write() override { return _sink->can_write(); } }; class OlapTableSinkOperatorX;