Skip to content

Commit c5cea88

Browse files
gridnevvvitgridnevvvit
committed
remove some portion of stream lookup tests
1 parent 45f8fc2 commit c5cea88

24 files changed

+139
-326
lines changed

‎ydb/core/kqp/ut/cost/kqp_cost_ut.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,8 @@ using namespace NYdb::NTable;
1414

1515
static NKikimrConfig::TAppConfig GetAppConfig(bool scanSourceRead = false, bool streamLookup = true, bool streamLookupJoin = false, bool enableOltpSink = false) {
1616
auto app = NKikimrConfig::TAppConfig();
17+
Y_UNUSED(streamLookup);
1718
app.MutableTableServiceConfig()->SetEnableKqpScanQuerySourceRead(scanSourceRead);
18-
app.MutableTableServiceConfig()->SetEnableKqpDataQueryStreamLookup(streamLookup);
1919
app.MutableTableServiceConfig()->SetEnableKqpDataQueryStreamIdxLookupJoin(streamLookupJoin);
2020
app.MutableTableServiceConfig()->SetEnableOlapSink(true);
2121
app.MutableTableServiceConfig()->SetEnableOltpSink(enableOltpSink);
@@ -676,7 +676,7 @@ Y_UNIT_TEST_SUITE(KqpCost) {
676676
auto result = session.ExecuteQuery(query, txControl, GetQuerySettings()).ExtractValueSync();
677677
// TODO: fix status?
678678
UNIT_ASSERT_VALUES_EQUAL(result.GetStatus(), EStatus::BAD_REQUEST);
679-
679+
680680
auto stats = NYdb::TProtoAccessor::GetProto(*result.GetStats());
681681

682682
Cerr << stats.DebugString() << Endl;

‎ydb/core/kqp/ut/effects/kqp_inplace_update_ut.cpp

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,6 @@ void Test(
6969

7070
// source read and stream lookup use iterator interface, that doesn't use datashard transactions
7171
NKikimrConfig::TAppConfig appConfig;
72-
appConfig.MutableTableServiceConfig()->SetEnableKqpDataQueryStreamLookup(false);
7372

7473
auto settings = TKikimrSettings()
7574
.SetAppConfig(appConfig)
@@ -370,7 +369,6 @@ Y_UNIT_TEST(BigRow) {
370369

371370
// source read use iterator interface, that doesn't use datashard transactions
372371
NKikimrConfig::TAppConfig appConfig;
373-
appConfig.MutableTableServiceConfig()->SetEnableKqpDataQueryStreamLookup(false);
374372

375373
auto settings = TKikimrSettings()
376374
.SetAppConfig(appConfig)

‎ydb/core/kqp/ut/indexes/kqp_indexes_multishard_ut.cpp

Lines changed: 6 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -1641,10 +1641,8 @@ Y_UNIT_TEST_SUITE(KqpMultishardIndex) {
16411641
}
16421642
}
16431643

1644-
Y_UNIT_TEST_TWIN(DataColumnUpsertMixedSemantic, StreamLookup) {
1644+
Y_UNIT_TEST(DataColumnUpsertMixedSemantic) {
16451645
NKikimrConfig::TAppConfig appConfig;
1646-
appConfig.MutableTableServiceConfig()->SetEnableKqpDataQueryStreamLookup(StreamLookup);
1647-
16481646
auto setting = NKikimrKqp::TKqpSetting();
16491647
auto serverSettings = TKikimrSettings()
16501648
.SetAppConfig(appConfig)
@@ -1689,10 +1687,8 @@ Y_UNIT_TEST_SUITE(KqpMultishardIndex) {
16891687
}
16901688
}
16911689

1692-
Y_UNIT_TEST_TWIN(DataColumnWriteNull, StreamLookup) {
1690+
Y_UNIT_TEST(DataColumnWriteNull) {
16931691
NKikimrConfig::TAppConfig appConfig;
1694-
appConfig.MutableTableServiceConfig()->SetEnableKqpDataQueryStreamLookup(StreamLookup);
1695-
16961692
auto setting = NKikimrKqp::TKqpSetting();
16971693
auto serverSettings = TKikimrSettings()
16981694
.SetAppConfig(appConfig)
@@ -1771,9 +1767,8 @@ Y_UNIT_TEST_SUITE(KqpMultishardIndex) {
17711767
}
17721768
}
17731769

1774-
Y_UNIT_TEST_TWIN(DataColumnWrite, StreamLookup) {
1770+
Y_UNIT_TEST(DataColumnWrite) {
17751771
NKikimrConfig::TAppConfig appConfig;
1776-
appConfig.MutableTableServiceConfig()->SetEnableKqpDataQueryStreamLookup(StreamLookup);
17771772

17781773
auto setting = NKikimrKqp::TKqpSetting();
17791774
auto serverSettings = TKikimrSettings()
@@ -2171,9 +2166,8 @@ Y_UNIT_TEST_SUITE(KqpMultishardIndex) {
21712166
}
21722167
}
21732168

2174-
Y_UNIT_TEST_TWIN(DataColumnSelect, StreamLookup) {
2169+
Y_UNIT_TEST(DataColumnSelect) {
21752170
NKikimrConfig::TAppConfig appConfig;
2176-
appConfig.MutableTableServiceConfig()->SetEnableKqpDataQueryStreamLookup(StreamLookup);
21772171

21782172
auto setting = NKikimrKqp::TKqpSetting();
21792173
auto serverSettings = TKikimrSettings()
@@ -2268,9 +2262,8 @@ Y_UNIT_TEST_SUITE(KqpMultishardIndex) {
22682262
}
22692263
}
22702264

2271-
Y_UNIT_TEST_TWIN(DuplicateUpsert, StreamLookup) {
2265+
Y_UNIT_TEST(DuplicateUpsert) {
22722266
NKikimrConfig::TAppConfig appConfig;
2273-
appConfig.MutableTableServiceConfig()->SetEnableKqpDataQueryStreamLookup(StreamLookup);
22742267

22752268
auto setting = NKikimrKqp::TKqpSetting();
22762269
auto serverSettings = TKikimrSettings()
@@ -2304,10 +2297,8 @@ Y_UNIT_TEST_SUITE(KqpMultishardIndex) {
23042297
}
23052298
}
23062299

2307-
Y_UNIT_TEST_TWIN(SortByPk, StreamLookup) {
2300+
Y_UNIT_TEST(SortByPk) {
23082301
NKikimrConfig::TAppConfig appConfig;
2309-
appConfig.MutableTableServiceConfig()->SetEnableKqpDataQueryStreamLookup(StreamLookup);
2310-
23112302
auto serverSettings = TKikimrSettings()
23122303
.SetAppConfig(appConfig);
23132304

‎ydb/core/kqp/ut/indexes/kqp_indexes_ut.cpp

Lines changed: 16 additions & 60 deletions
Original file line numberDiff line numberDiff line change
@@ -2796,24 +2796,11 @@ Y_UNIT_TEST_SUITE(KqpIndexes) {
27962796

27972797
auto& stats = NYdb::TProtoAccessor::GetProto(*result.GetStats());
27982798

2799-
if (serverSettings.AppConfig.GetTableServiceConfig().GetEnableKqpDataQueryStreamLookup()) {
2800-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access().size(), 2);
2801-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(0).name(), "/Root/TestTable");
2802-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(0).reads().rows(), 3);
2803-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(1).name(), "/Root/TestTable/ix_cust/indexImplTable");
2804-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(1).reads().rows(), 3);
2805-
} else {
2806-
int indexPhaseId = 0;
2807-
int tablePhaseId = 1;
2808-
2809-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(tablePhaseId).table_access().size(), 1);
2810-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(tablePhaseId).table_access(0).name(), "/Root/TestTable");
2811-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(tablePhaseId).table_access(0).reads().rows(), 3);
2812-
2813-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(indexPhaseId).table_access().size(), 1);
2814-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(indexPhaseId).table_access(0).name(), "/Root/TestTable/ix_cust/indexImplTable");
2815-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(indexPhaseId).table_access(0).reads().rows(), 3);
2816-
}
2799+
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access().size(), 2);
2800+
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(0).name(), "/Root/TestTable");
2801+
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(0).reads().rows(), 3);
2802+
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(1).name(), "/Root/TestTable/ix_cust/indexImplTable");
2803+
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(1).reads().rows(), 3);
28172804
}
28182805
}
28192806

@@ -2844,24 +2831,11 @@ Y_UNIT_TEST_SUITE(KqpIndexes) {
28442831

28452832
auto& stats = NYdb::TProtoAccessor::GetProto(*result.GetStats());
28462833

2847-
if (serverSettings.AppConfig.GetTableServiceConfig().GetEnableKqpDataQueryStreamLookup()) {
2848-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access().size(), 2);
2849-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(0).name(), "/Root/TestTable");
2850-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(0).reads().rows(), 2);
2851-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(1).name(), "/Root/TestTable/ix_cust2/indexImplTable");
2852-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(1).reads().rows(), 2);
2853-
} else {
2854-
int indexPhaseId = 0;
2855-
int tablePhaseId = 1;
2856-
2857-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(tablePhaseId).table_access().size(), 1);
2858-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(tablePhaseId).table_access(0).name(), "/Root/TestTable");
2859-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(tablePhaseId).table_access(0).reads().rows(), 2);
2860-
2861-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(indexPhaseId).table_access().size(), 1);
2862-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(indexPhaseId).table_access(0).name(), "/Root/TestTable/ix_cust2/indexImplTable");
2863-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(indexPhaseId).table_access(0).reads().rows(), 2);
2864-
}
2834+
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access().size(), 2);
2835+
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(0).name(), "/Root/TestTable");
2836+
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(0).reads().rows(), 2);
2837+
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(1).name(), "/Root/TestTable/ix_cust2/indexImplTable");
2838+
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(1).reads().rows(), 2);
28652839
}
28662840
}
28672841

@@ -4855,7 +4829,6 @@ R"([[#;#;["Primary1"];[41u]];[["Secondary2"];[2u];["Primary2"];[42u]];[["Seconda
48554829
.SetKqpSettings({setting});
48564830

48574831
NKikimrConfig::TAppConfig appConfig;
4858-
appConfig.MutableTableServiceConfig()->SetEnableKqpDataQueryStreamLookup(true);
48594832
appConfig.MutableTableServiceConfig()->SetEnableKqpDataQueryStreamIdxLookupJoin(true);
48604833
// setting channel buffer size so small to make sure that we will be able to transfer at least
48614834
// one row in stream lookup.
@@ -4998,30 +4971,13 @@ R"([[#;#;["Primary1"];[41u]];[["Secondary2"];[2u];["Primary2"];[42u]];[["Seconda
49984971

49994972
auto& stats = NYdb::TProtoAccessor::GetProto(*result2.GetStats());
50004973

5001-
int readPhase = 0;
5002-
if (serverSettings.AppConfig.GetTableServiceConfig().GetEnableKqpDataQueryStreamLookup()) {
5003-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 1);
5004-
5005-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(readPhase).table_access().size(), 2);
5006-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(readPhase).table_access(0).name(), "/Root/SecondaryComplexKeys");
5007-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(readPhase).table_access(0).reads().rows(), 1);
5008-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(readPhase).table_access(1).name(), "/Root/SecondaryComplexKeys/Index/indexImplTable");
5009-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(readPhase).table_access(1).reads().rows(), 1);
5010-
} else {
5011-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 3);
5012-
5013-
readPhase++;
5014-
5015-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(readPhase).table_access().size(), 1);
5016-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(readPhase).table_access(0).name(), "/Root/SecondaryComplexKeys/Index/indexImplTable");
5017-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(readPhase).table_access(0).reads().rows(), 1);
5018-
5019-
readPhase++;
4974+
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 1);
50204975

5021-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(readPhase).table_access().size(), 1);
5022-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(readPhase).table_access(0).name(), "/Root/SecondaryComplexKeys");
5023-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(readPhase).table_access(0).reads().rows(), 1);
5024-
}
4976+
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access().size(), 2);
4977+
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(0).name(), "/Root/SecondaryComplexKeys");
4978+
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(0).reads().rows(), 1);
4979+
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(1).name(), "/Root/SecondaryComplexKeys/Index/indexImplTable");
4980+
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(1).reads().rows(), 1);
50254981
}
50264982
}
50274983

‎ydb/core/kqp/ut/join/kqp_index_lookup_join_ut.cpp

Lines changed: 12 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ void PrepareTables(TSession session) {
7575
(1, "Value1"),
7676
(2, "Value2"),
7777
(3, "Value3"),
78-
(4, "Value4");
78+
(4, "Value4");
7979
8080
REPLACE INTO `/Root/LaunchByProcessIdAndPinned` (idx_processId, idx_pinned, idx_launchNumber) VALUES
8181
("eProcess", false, 4),
@@ -133,7 +133,7 @@ void Test(const TString& query, const TString& answer, size_t rightTableReads, b
133133
UNIT_ASSERT_VALUES_EQUAL(tableStat.reads().rows(), rightTableReads);
134134
}
135135
}
136-
} else if (settings.AppConfig.GetTableServiceConfig().GetEnableKqpDataQueryStreamLookup()) {
136+
} else {
137137
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 2);
138138

139139
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access().size(), 1);
@@ -143,18 +143,6 @@ void Test(const TString& query, const TString& answer, size_t rightTableReads, b
143143
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(1).table_access().size(), 1);
144144
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(1).table_access(0).name(), "/Root/Right");
145145
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(1).table_access(0).reads().rows(), rightTableReads);
146-
} else {
147-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 3);
148-
149-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access().size(), 1);
150-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(0).name(), "/Root/Left");
151-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(0).reads().rows(), 7);
152-
153-
UNIT_ASSERT(stats.query_phases(1).table_access().empty()); // keys extraction for lookups
154-
155-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(2).table_access().size(), 1);
156-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(2).table_access(0).name(), "/Root/Right");
157-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(2).table_access(0).reads().rows(), rightTableReads);
158146
}
159147
}
160148

@@ -575,7 +563,7 @@ Y_UNIT_TEST_TWIN(LeftSemiJoinWithLeftFilter, StreamLookup) {
575563
FROM `/Root/Left` AS l
576564
LEFT SEMI JOIN `/Root/Right` AS r
577565
ON l.Fk = r.Key
578-
WHERE l.Value != 'Value1'
566+
WHERE l.Value != 'Value1'
579567
ORDER BY l.Value
580568
)",
581569
R"([
@@ -651,10 +639,8 @@ void TestKeyCastForAllJoinTypes(TSession session, const TString& leftTable, cons
651639

652640
if (settings.AppConfig.GetTableServiceConfig().GetEnableKqpDataQueryStreamIdxLookupJoin()) {
653641
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 1);
654-
} else if (settings.AppConfig.GetTableServiceConfig().GetEnableKqpDataQueryStreamLookup()) {
655-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 2);
656642
} else {
657-
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 3);
643+
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 2);
658644
}
659645
}
660646
}
@@ -728,8 +714,7 @@ void TestKeyCast(const TKikimrSettings& settings, TSession session, const TStrin
728714
const TString query = GetQuery(joinType, leftTable, rightTable);
729715
auto result = session.ExecuteDataQuery(Q_(query), TTxControl::BeginTx().CommitTx(), execSettings).ExtractValueSync();
730716

731-
ui32 index = settings.AppConfig.GetTableServiceConfig().GetEnableKqpDataQueryStreamIdxLookupJoin() ? 0
732-
: (settings.AppConfig.GetTableServiceConfig().GetEnableKqpDataQueryStreamLookup() ? 1 : 2);
717+
ui32 index = settings.AppConfig.GetTableServiceConfig().GetEnableKqpDataQueryStreamIdxLookupJoin() ? 0 : 1;
733718

734719
CompareYson(answer, FormatResultSetYson(result.GetResultSet(0)));
735720

@@ -764,7 +749,7 @@ Y_UNIT_TEST_QUAD(CheckCastInt32ToInt16, StreamLookupJoin, NotNull) {
764749
(-32769, "Value12");
765750
REPLACE INTO `/Root/{rightTable}` (Key, Value) VALUES
766751
(1, "Value21"),
767-
(32767, "Value22");
752+
(32767, "Value22");
768753
)",
769754
"leftTable"_a = leftKeyColumnType,
770755
"rightTable"_a = rightTableName
@@ -777,7 +762,7 @@ Y_UNIT_TEST_QUAD(CheckCastInt32ToInt16, StreamLookupJoin, NotNull) {
777762
[[1];["Value11"];[1];["Value21"]]
778763
])";
779764

780-
TestKeyCast(settings, session, "LEFT", leftKeyColumnType, rightTableName, answer, StreamLookupJoin ? 1 : 2);
765+
TestKeyCast(settings, session, "LEFT", leftKeyColumnType, rightTableName, answer, StreamLookupJoin ? 1 : 2);
781766
}
782767

783768
Y_UNIT_TEST_QUAD(CheckCastUint32ToUint16, StreamLookupJoin, NotNull) {
@@ -816,7 +801,7 @@ Y_UNIT_TEST_QUAD(CheckCastUint32ToUint16, StreamLookupJoin, NotNull) {
816801
[[4294967295u];["Value12"];#;#]
817802
])";
818803

819-
TestKeyCast(settings, session, "LEFT", leftKeyColumnType, rightTableName, answer, StreamLookupJoin ? 1 : 2);
804+
TestKeyCast(settings, session, "LEFT", leftKeyColumnType, rightTableName, answer, StreamLookupJoin ? 1 : 2);
820805
}
821806

822807
Y_UNIT_TEST_QUAD(CheckCastUint64ToInt64, StreamLookupJoin, NotNull) {
@@ -857,7 +842,7 @@ Y_UNIT_TEST_QUAD(CheckCastUint64ToInt64, StreamLookupJoin, NotNull) {
857842
[[18446744073709551615u];["Value11"];#;#]
858843
])";
859844

860-
TestKeyCast(settings, session, "LEFT", leftKeyColumnType, rightTableName, answer, StreamLookupJoin ? 1 : 2);
845+
TestKeyCast(settings, session, "LEFT", leftKeyColumnType, rightTableName, answer, StreamLookupJoin ? 1 : 2);
861846
}
862847

863848
Y_UNIT_TEST_QUAD(CheckCastInt64ToUint64, StreamLookupJoin, NotNull) {
@@ -896,7 +881,7 @@ Y_UNIT_TEST_QUAD(CheckCastInt64ToUint64, StreamLookupJoin, NotNull) {
896881
[[1];["Value11"];[1u];["Value22"]]
897882
])";
898883

899-
TestKeyCast(settings, session, "LEFT", leftKeyColumnType, rightTableName, answer, StreamLookupJoin ? 1 : 2);
884+
TestKeyCast(settings, session, "LEFT", leftKeyColumnType, rightTableName, answer, StreamLookupJoin ? 1 : 2);
900885
}
901886

902887
Y_UNIT_TEST_QUAD(CheckCastUtf8ToString, StreamLookupJoin, NotNull) {
@@ -971,7 +956,7 @@ Y_UNIT_TEST_TWIN(JoinByComplexKeyWithNullComponents, StreamLookupJoin) {
971956
(1, "one", "value1"),
972957
(2, NULL, "value2"),
973958
(NULL, "three", "value3");
974-
959+
975960
REPLACE INTO `/Root/Right` (Key1, Key2, Value) VALUES
976961
(1, "one", "value1"),
977962
(2, NULL, "value2"),
@@ -1216,7 +1201,7 @@ Y_UNIT_TEST_TWIN(LeftSemiJoinWithDuplicatesInRightTable, StreamLookupJoin) {
12161201
(1, 10, "value1"),
12171202
(2, 20, "value2"),
12181203
(3, 30, "value3");
1219-
1204+
12201205
REPLACE INTO `/Root/Right` (Key1, Key2, Value) VALUES
12211206
(10, 100, "value1"),
12221207
(10, 101, "value1"),

0 commit comments

Comments
 (0)