diff --git a/ydb/library/yql/providers/yt/comp_nodes/dq/dq_yt_rpc_helpers.cpp b/ydb/library/yql/providers/yt/comp_nodes/dq/dq_yt_rpc_helpers.cpp index ff80d44259c5..2f3b44816df4 100644 --- a/ydb/library/yql/providers/yt/comp_nodes/dq/dq_yt_rpc_helpers.cpp +++ b/ydb/library/yql/providers/yt/comp_nodes/dq/dq_yt_rpc_helpers.cpp @@ -43,6 +43,7 @@ std::unique_ptr CreateInputStreams(bool isArrow, const TString& auto request = apiServiceProxy.ReadTable(); client->InitStreamingRequest(*request); + request->ServerAttachmentsStreamingParameters().WriteTimeout = TDuration::MilliSeconds(timeout); request->ClientAttachmentsStreamingParameters().ReadTimeout = TDuration::MilliSeconds(timeout); TString ppath;