[fix](tvf) fix tvf return error since thrift message too large to reach limit

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

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

be/src/util/thrift_client.h

@@ -123,6 +123,7 @@ template <class InterfaceType>
 ThriftClient<InterfaceType>::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<InterfaceType>::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;