diff --git a/be/src/exec/es/es_scan_reader.cpp b/be/src/exec/es/es_scan_reader.cpp index 158b760325..183719fc7c 100644 --- a/be/src/exec/es/es_scan_reader.cpp +++ b/be/src/exec/es/es_scan_reader.cpp @@ -124,6 +124,7 @@ Status ESScanReader::open() { } _network_client.set_basic_auth(_user_name, _passwd); _network_client.set_content_type("application/json"); + _network_client.set_timeout_ms(_http_timeout_ms); if (_use_ssl_client) { _network_client.use_untrusted_ssl(); } @@ -214,7 +215,7 @@ Status ESScanReader::close() { _network_client.set_basic_auth(_user_name, _passwd); _network_client.set_method(DELETE); _network_client.set_content_type("application/json"); - _network_client.set_timeout_ms(5 * 1000); + _network_client.set_timeout_ms(_http_timeout_ms); if (_use_ssl_client) { _network_client.use_untrusted_ssl(); }