diff options
| author | ignat <ignat@yandex-team.com> | 2024-09-07 17:11:53 +0300 |
|---|---|---|
| committer | ignat <ignat@yandex-team.com> | 2024-09-07 17:20:24 +0300 |
| commit | 8041f1568aca965fdc3dcdea45238bbf4b7be6d8 (patch) | |
| tree | 4f5dcc6bfa63b71d60a3e0cea0eaeb117c286aec | |
| parent | fb7e2db618ca57793e256a099677433c3f8a3005 (diff) | |
| download | ydb-8041f1568aca965fdc3dcdea45238bbf4b7be6d8.tar.gz | |
YT-22431: Small preparations to use yt/yt/client with system protobuf
17ec916976b7cb9ed4adcee4fdbd25d805aed4df
| -rw-r--r-- | yt/yt/client/api/rpc_proxy/row_stream.cpp | 4 | ||||
| -rw-r--r-- | yt/yt/client/bundle_controller_client/bundle_controller_settings.cpp | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/yt/yt/client/api/rpc_proxy/row_stream.cpp b/yt/yt/client/api/rpc_proxy/row_stream.cpp index de999f1d2e..0bc5e09439 100644 --- a/yt/yt/client/api/rpc_proxy/row_stream.cpp +++ b/yt/yt/client/api/rpc_proxy/row_stream.cpp @@ -42,7 +42,7 @@ std::tuple<TSharedRef, TMutableRef> SerializeRowStreamBlockEnvelope( if (statistics) { totalSize += sizeof (i32); // partCount totalSize += sizeof (i64) * 2; // partLength * 2 - totalSize += statistics->ByteSize(); + totalSize += statistics->ByteSizeLong(); } struct TSerializedRowStreamBlockTag { }; @@ -82,7 +82,7 @@ std::tuple<TSharedRef, TMutableRef> SerializeRowStreamBlockEnvelope( skipPayload(); if (statistics) { - writeInt64(statistics->ByteSize()); // partLength + writeInt64(statistics->ByteSizeLong()); // partLength writeProto(*statistics); } diff --git a/yt/yt/client/bundle_controller_client/bundle_controller_settings.cpp b/yt/yt/client/bundle_controller_client/bundle_controller_settings.cpp index a2547ee541..7aa460a7e3 100644 --- a/yt/yt/client/bundle_controller_client/bundle_controller_settings.cpp +++ b/yt/yt/client/bundle_controller_client/bundle_controller_settings.cpp @@ -261,7 +261,7 @@ void ToProto(NBundleController::NProto::TBundleConfigConstraints* protoBundleCon void FromProto(TBundleConfigConstraintsPtr bundleConfigConstraints, const NBundleController::NProto::TBundleConfigConstraints* protoBundleConfigConstraints) { - auto rpcProxySizes = protoBundleConfigConstraints->get_arr_rpc_proxy_sizes(); + auto rpcProxySizes = protoBundleConfigConstraints->rpc_proxy_sizes(); for (auto instance : rpcProxySizes) { auto newInstance = New<TInstanceSize>(); @@ -269,7 +269,7 @@ void FromProto(TBundleConfigConstraintsPtr bundleConfigConstraints, const NBundl bundleConfigConstraints->RpcProxySizes.push_back(newInstance); } - auto tabletNodeSizes = protoBundleConfigConstraints->get_arr_tablet_node_sizes(); + auto tabletNodeSizes = protoBundleConfigConstraints->tablet_node_sizes(); for (auto instance : tabletNodeSizes) { auto newInstance = New<TInstanceSize>(); |