From 773c932ae6bea1fe21900237e37f82aa3248a041 Mon Sep 17 00:00:00 2001
From: Siyang Tang <82279870+TangSiyang2001@users.noreply.github.com>
Date: Tue, 2 Jan 2024 11:16:06 +0800
Subject: [PATCH] [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 72b6a15e733a939..1e68f9e98d3b216 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 @@ 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;