aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorlpetrov02 <lpetrov02@yandex-team.com>2023-02-16 10:20:45 +0300
committerlpetrov02 <lpetrov02@yandex-team.com>2023-02-16 10:20:45 +0300
commit81df0ab704d8b172085f8e97c236ca88c102d907 (patch)
treee5467b991d209f02fb7805c1f0ce30f548415a35
parentfe2e305243b3643740b1178a9893de33e94a1367 (diff)
downloadydb-81df0ab704d8b172085f8e97c236ca88c102d907.tar.gz
Fills 'StreamArn' for 'DescribeStream' + test
Fills the 'StreamArn' field for the 'DescribeStream' method + a test that check if the 'DescribeSTream' return same values in fields 'StreamName' and 'StreamArn'
-rw-r--r--ydb/services/datastreams/datastreams_proxy.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/services/datastreams/datastreams_proxy.cpp b/ydb/services/datastreams/datastreams_proxy.cpp
index a12a8e1288b..bb553fb1d4f 100644
--- a/ydb/services/datastreams/datastreams_proxy.cpp
+++ b/ydb/services/datastreams/datastreams_proxy.cpp
@@ -672,7 +672,7 @@ namespace NKikimr::NDataStreams::V1 {
ui32 writeSpeed = pqConfig.GetPartitionConfig().GetWriteSpeedInBytesPerSecond() / 1_KB;
auto& description = *result.mutable_stream_description();
description.set_stream_name(GetProtoRequest()->stream_name());
- description.set_stream_arn(GetProtoRequest()->stream_name()); // Added by lpetrov02 for testing
+ description.set_stream_arn(GetProtoRequest()->stream_name());
ui32 retentionPeriodHours = TInstant::Seconds(pqConfig.GetPartitionConfig().GetLifetimeSeconds()).Hours();
description.set_retention_period_hours(retentionPeriodHours);
description.set_write_quota_kb_per_sec(writeSpeed);