From 9e7387182a7917c2a4f63d13372600ab1803a258 Mon Sep 17 00:00:00 2001 From: Konstantin Podshumok Date: Sat, 2 Mar 2019 02:11:44 +0300 Subject: [PATCH] StorageReplicatedMergeTree: move timeouts to RemoteBlockInputStream --- dbms/src/Storages/StorageReplicatedMergeTree.cpp | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/dbms/src/Storages/StorageReplicatedMergeTree.cpp b/dbms/src/Storages/StorageReplicatedMergeTree.cpp index 235d31c63a2..4f8629976e1 100644 --- a/dbms/src/Storages/StorageReplicatedMergeTree.cpp +++ b/dbms/src/Storages/StorageReplicatedMergeTree.cpp @@ -3986,8 +3986,6 @@ void StorageReplicatedMergeTree::sendRequestToLeaderReplica(const ASTPtr & query else throw Exception("Can't proxy this query. Unsupported query type", ErrorCodes::NOT_IMPLEMENTED); - auto timeouts = ConnectionTimeouts::getTCPTimeoutsWithoutFailover(global_context.getSettingsRef()); - const auto & query_settings = query_context.getSettingsRef(); const auto & query_client_info = query_context.getClientInfo(); String user = query_client_info.current_user; @@ -4003,7 +4001,7 @@ void StorageReplicatedMergeTree::sendRequestToLeaderReplica(const ASTPtr & query leader_address.host, leader_address.queries_port, leader_address.database, - user, password, timeouts, "Follower replica"); + user, password, "Follower replica"); std::stringstream new_query_ss; formatAST(*new_query, new_query_ss, false, true);