This is an automated email from the ASF dual-hosted git repository.
lihaopeng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 6371dbab33b [Pipeline](load) fix may oom in pipeline load (#27714)
6371dbab33b is described below
commit 6371dbab33bb6644500fe9469cab697adf57efad
Author: HappenLee <[email protected]>
AuthorDate: Wed Nov 29 10:20:59 2023 +0800
[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 9330f9520e0..762fee5982e 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;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
