This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 7cb32395994 [fix](sink) add writting restriction for
OlapTableSinkV2Operator (#29340)
7cb32395994 is described below
commit 7cb323959949dd256a18517135574386d5630853
Author: Siyang Tang <[email protected]>
AuthorDate: Tue Jan 2 11:16:06 2024 +0800
[fix](sink) add writting restriction for OlapTableSinkV2Operator (#29340)
---
be/src/pipeline/exec/olap_table_sink_v2_operator.h | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/be/src/pipeline/exec/olap_table_sink_v2_operator.h
b/be/src/pipeline/exec/olap_table_sink_v2_operator.h
index 72b6a15e733..1e68f9e98d3 100644
--- a/be/src/pipeline/exec/olap_table_sink_v2_operator.h
+++ b/be/src/pipeline/exec/olap_table_sink_v2_operator.h
@@ -39,7 +39,7 @@ public:
OlapTableSinkV2Operator(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 OlapTableSinkV2OperatorX;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
