[fix](sink) add writting restriction for OlapTableSinkV2Operator (apa…

…che#29340)
HappenLee · Jan 12, 2024 · 773c932 · 773c932
1 parent 69802da
commit 773c932
Showing 1 changed file with 1 addition and 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
@@ -39,7 +39,7 @@ class OlapTableSinkV2Operator final : public DataSinkOperator<vectorized::VOlapT
     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;