From a7d90e19720bb83eb91c6560e45ac475ed53eda3 Mon Sep 17 00:00:00 2001 From: kungasc Date: Thu, 16 May 2024 18:25:14 +0000 Subject: [PATCH] fix kqp scan test --- ydb/core/kqp/ut/scan/kqp_scan_ut.cpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/ydb/core/kqp/ut/scan/kqp_scan_ut.cpp b/ydb/core/kqp/ut/scan/kqp_scan_ut.cpp index 689c9e1e39e9..e8bb6f3034b5 100644 --- a/ydb/core/kqp/ut/scan/kqp_scan_ut.cpp +++ b/ydb/core/kqp/ut/scan/kqp_scan_ut.cpp @@ -2364,8 +2364,8 @@ Y_UNIT_TEST_SUITE(KqpScan) { bool firstAttemptToGetData = false; auto captureEvents = [&](TTestActorRuntimeBase&, TAutoPtr& ev) { - if (ev->GetTypeRewrite() == TEvTxProxySchemeCache::TEvNavigateKeySetResult::EventType) { - Cerr << "Captured TEvTxProxySchemeCache::TEvNavigateKeySetResult from " << runtime->FindActorName(ev->Sender) << " to " << runtime->FindActorName(ev->GetRecipientRewrite()) << Endl; + if (ev->GetTypeRewrite() == TEvTxProxySchemeCache::TEvResolveKeySetResult::EventType) { + Cerr << "Captured TEvTxProxySchemeCache::TEvResolveKeySetResult from " << runtime->FindActorName(ev->Sender) << " to " << runtime->FindActorName(ev->GetRecipientRewrite()) << Endl; if (runtime->FindActorName(ev->GetRecipientRewrite()) == "KQP_STREAM_LOOKUP_ACTOR") { if (!firstAttemptToGetData) { // capture response from scheme cache until CA calls GetAsyncInputData() @@ -2428,13 +2428,13 @@ Y_UNIT_TEST_SUITE(KqpScan) { createTable(createSession(), R"( --!syntax_v1 - CREATE TABLE `/Root/Table` (Key int32, Value int32, PRIMARY KEY(Key)); + CREATE TABLE `/Root/Table` (Key int32, Fk int32, Value int32, PRIMARY KEY(Key), INDEX Index GLOBAL ON (Fk)); )"); server->GetRuntime()->SetEventFilter(captureEvents); sendQuery(R"( - SELECT Value FROM `/Root/Table` WHERE Key IN AsList(1, 2, 3); + SELECT Value FROM `/Root/Table` VIEW Index WHERE Fk IN AsList(1, 2, 3); )"); }