From 6371dbab33bb6644500fe9469cab697adf57efad Mon Sep 17 00:00:00 2001 From: HappenLee Date: Wed, 29 Nov 2023 10:20:59 +0800 Subject: [PATCH] [Pipeline](load) fix may oom in pipeline load (#27714) --- be/src/pipeline/exec/olap_table_sink_operator.h | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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;