diff options
| author | a-romanov <Anton.Romanov@ydb.tech> | 2022-07-19 19:20:00 +0300 |
|---|---|---|
| committer | a-romanov <Anton.Romanov@ydb.tech> | 2022-07-19 19:20:00 +0300 |
| commit | 5e561dc030f602c54a8549749d885b5f9547f31d (patch) | |
| tree | fdc485abd91b26bfa5c28fc7cd3cfe1f9ed4da0e | |
| parent | 2b081971d7f28bca4523004ec04664987c4d3895 (diff) | |
| download | ydb-5e561dc030f602c54a8549749d885b5f9547f31d.tar.gz | |
Fix.
| -rw-r--r-- | ydb/library/yql/providers/clickhouse/actors/yql_ch_read_actor.cpp | 2 | ||||
| -rw-r--r-- | ydb/library/yql/providers/clickhouse/provider/yql_clickhouse_load_meta.cpp | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/ydb/library/yql/providers/clickhouse/actors/yql_ch_read_actor.cpp b/ydb/library/yql/providers/clickhouse/actors/yql_ch_read_actor.cpp index fa9c5221f7f..43bf99778f1 100644 --- a/ydb/library/yql/providers/clickhouse/actors/yql_ch_read_actor.cpp +++ b/ydb/library/yql/providers/clickhouse/actors/yql_ch_read_actor.cpp @@ -62,7 +62,7 @@ public: void Bootstrap() { Become(&TClickHouseReadActor::StateFunc); - Gateway->Download(Url, {}, 0U, std::bind(&TClickHouseReadActor::OnDownloadFinished, ActorSystem, SelfId(), std::placeholders::_1), Query); + Gateway->Upload(Url, {}, Query, std::bind(&TClickHouseReadActor::OnDownloadFinished, ActorSystem, SelfId(), std::placeholders::_1)); } static constexpr char ActorName[] = "ClickHouse_READ_ACTOR"; diff --git a/ydb/library/yql/providers/clickhouse/provider/yql_clickhouse_load_meta.cpp b/ydb/library/yql/providers/clickhouse/provider/yql_clickhouse_load_meta.cpp index eeb56b8fb04..2655d03652a 100644 --- a/ydb/library/yql/providers/clickhouse/provider/yql_clickhouse_load_meta.cpp +++ b/ydb/library/yql/providers/clickhouse/provider/yql_clickhouse_load_meta.cpp @@ -113,7 +113,7 @@ public: auto promise = NThreading::NewPromise(); handles.emplace_back(promise.GetFuture()); - Gateway_->Download(std::move(url), {}, 0U, std::bind(&TClickHouseLoadTableMetadataTransformer::OnDiscovery, Results_.emplace(item, std::make_shared<TMapType::mapped_type::element_type>()).first->second, std::placeholders::_1, std::move(promise)), std::move(sql)); + Gateway_->Upload(std::move(url), {}, std::move(sql), std::bind(&TClickHouseLoadTableMetadataTransformer::OnDiscovery, Results_.emplace(item, std::make_shared<TMapType::mapped_type::element_type>()).first->second, std::placeholders::_1, std::move(promise))); } if (handles.empty()) { |