From a90a69ea1169cc2071ac95aba5c4ce71f2700901 Mon Sep 17 00:00:00 2001 From: Guangming Lu Date: Fri, 27 Mar 2026 09:46:13 +0800 Subject: [PATCH 1/2] [fix] fix tvf return error since thrift message too large to reach limit --- be/src/util/thrift_client.h | 3 +++ 1 file changed, 3 insertions(+) diff --git a/be/src/util/thrift_client.h b/be/src/util/thrift_client.h index ccce45f62894c0..faed22e2a9ea7d 100644 --- a/be/src/util/thrift_client.h +++ b/be/src/util/thrift_client.h @@ -123,6 +123,7 @@ template ThriftClient::ThriftClient(const std::string& ipaddress, int port) : ThriftClientImpl(ipaddress, port) { _transport.reset(new apache::thrift::transport::TBufferedTransport(_socket)); + _transport->getConfiguration()->setMaxMessageSize(config::thrift_max_message_size); _protocol.reset(new apache::thrift::protocol::TBinaryProtocol(_transport)); _iface.reset(new InterfaceType(_protocol)); } @@ -134,10 +135,12 @@ ThriftClient::ThriftClient(const std::string& ipaddress, int port switch (server_type) { case ThriftServer::NON_BLOCKING: _transport.reset(new apache::thrift::transport::TFramedTransport(_socket)); + _transport->getConfiguration()->setMaxMessageSize(config::thrift_max_message_size); break; case ThriftServer::THREADED: case ThriftServer::THREAD_POOL: _transport.reset(new apache::thrift::transport::TBufferedTransport(_socket)); + _transport->getConfiguration()->setMaxMessageSize(config::thrift_max_message_size); break; default: std::stringstream error_msg; From c68473dc71adeef1e379b7adfc83ca5fed7725f4 Mon Sep 17 00:00:00 2001 From: Guangming Lu Date: Fri, 27 Mar 2026 11:33:02 +0800 Subject: [PATCH 2/2] [fix](tvf) fix tvf return error since thrift message too large reach limit --- be/src/common/config.cpp | 2 +- be/src/common/config.h | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/be/src/common/config.cpp b/be/src/common/config.cpp index 54a65f7802af59..2e138fab6149f3 100644 --- a/be/src/common/config.cpp +++ b/be/src/common/config.cpp @@ -336,7 +336,7 @@ DEFINE_mInt32(thrift_connect_timeout_seconds, "3"); DEFINE_mInt64(thrift_client_retry_interval_ms, "1000"); // max message size of thrift request // default: 100 * 1024 * 1024 -DEFINE_mInt64(thrift_max_message_size, "104857600"); +DEFINE_mInt32(thrift_max_message_size, "104857600"); // max bytes number for single scan range, used in segmentv2 DEFINE_mInt32(doris_scan_range_max_mb, "1024"); // single read execute fragment row number diff --git a/be/src/common/config.h b/be/src/common/config.h index 07272806481235..1c4f3e3b318ecc 100644 --- a/be/src/common/config.h +++ b/be/src/common/config.h @@ -395,7 +395,7 @@ DECLARE_mInt32(thrift_connect_timeout_seconds); DECLARE_mInt64(thrift_client_retry_interval_ms); // max message size of thrift request // default: 100 * 1024 * 1024 -DECLARE_mInt64(thrift_max_message_size); +DECLARE_mInt32(thrift_max_message_size); // max bytes number for single scan range, used in segmentv2 DECLARE_mInt32(doris_scan_range_max_mb); // single read execute fragment row number