aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoralexnick <alexnick@yandex-team.ru>2022-02-22 15:38:26 +0300
committeralexnick <alexnick@yandex-team.ru>2022-02-22 15:38:26 +0300
commit3e5c61fb083629f80986c5634f8f7afec5107c2e (patch)
tree07d338d3dca83598e9f4ed3e78b3e26fe6919ea3
parentcb69ebfc910722a9ecfc2234d781f79e4a60fb60 (diff)
downloadydb-3e5c61fb083629f80986c5634f8f7afec5107c2e.tar.gz
fix for test KIKIMR-14230
ref:2b34a3efa72b7b4ac6508c06f664e38e3d07e746
-rw-r--r--ydb/core/persqueue/key.h6
-rw-r--r--ydb/core/persqueue/pq_ut.h4
2 files changed, 5 insertions, 5 deletions
diff --git a/ydb/core/persqueue/key.h b/ydb/core/persqueue/key.h
index 098c67cf7d..356c0cf6df 100644
--- a/ydb/core/persqueue/key.h
+++ b/ydb/core/persqueue/key.h
@@ -20,10 +20,10 @@ public:
};
enum EMark : char {
- MarkUserDeprecated = 'u',
- MarkSourceId = 's',
+ MarkUser = 'c',
MarkProtoSourceId = 'p',
- MarkUser = 'c'
+ MarkSourceId = 's',
+ MarkUserDeprecated = 'u'
};
TKeyPrefix(EType type, const ui32 partition)
diff --git a/ydb/core/persqueue/pq_ut.h b/ydb/core/persqueue/pq_ut.h
index cbba48c173..f5f961022c 100644
--- a/ydb/core/persqueue/pq_ut.h
+++ b/ydb/core/persqueue/pq_ut.h
@@ -961,9 +961,9 @@ TVector<TString> CmdSourceIdRead(TTestContext& tc) {
NPQ::TKeyPrefix ikeyFrom(NPQ::TKeyPrefix::TypeInfo, 0, NPQ::TKeyPrefix::MarkSourceId);
range->SetFrom(ikeyFrom.Data(), ikeyFrom.Size());
range->SetIncludeFrom(true);
- NPQ::TKeyPrefix ikeyTo(NPQ::TKeyPrefix::TypeInfo, 1, NPQ::TKeyPrefix::MarkSourceId);
+ NPQ::TKeyPrefix ikeyTo(NPQ::TKeyPrefix::TypeInfo, 0, NPQ::TKeyPrefix::MarkUserDeprecated);
range->SetTo(ikeyTo.Data(), ikeyTo.Size());
- range->SetIncludeTo(true);
+ range->SetIncludeTo(false);
Cout << request.Get()->ToString() << Endl;
tc.Runtime->SendToPipe(tc.TabletId, tc.Edge, request.Release(), 0, GetPipeConfigWithRetries());
result = tc.Runtime->GrabEdgeEvent<TEvKeyValue::TEvResponse>(handle);