Skip to content

Commit dfacff4

Browse files
committed
fix tests after merge
1 parent 7efac58 commit dfacff4

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

ydb/core/kqp/ut/olap/kqp_olap_stats_ut.cpp

+4-4
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ Y_UNIT_TEST_SUITE(KqpOlapStats) {
4848
tableInserter.AddRow().Add(i).Add("test_res_" + std::to_string(i)).AddNull();
4949
}
5050

51-
testHelper.InsertData(testTable, tableInserter);
51+
testHelper.BulkUpsert(testTable, tableInserter);
5252
}
5353

5454
Sleep(TDuration::Seconds(1));
@@ -88,7 +88,7 @@ Y_UNIT_TEST_SUITE(KqpOlapStats) {
8888
for (size_t i = 0; i < inserted_rows; i++) {
8989
tableInserter.AddRow().Add(i).Add("test_res_" + std::to_string(i)).AddNull();
9090
}
91-
testHelper.InsertData(testTable, tableInserter);
91+
testHelper.BulkUpsert(testTable, tableInserter);
9292
}
9393

9494
Sleep(TDuration::Seconds(1));
@@ -135,7 +135,7 @@ Y_UNIT_TEST_SUITE(KqpOlapStats) {
135135
.Add("test_res_" + std::to_string(i + t * tables_in_store))
136136
.AddNull();
137137
}
138-
testHelper.InsertData(testTable, tableInserter);
138+
testHelper.BulkUpsert(testTable, tableInserter);
139139
}
140140

141141
Sleep(TDuration::Seconds(20));
@@ -155,4 +155,4 @@ Y_UNIT_TEST_SUITE(KqpOlapStats) {
155155
}
156156

157157
} // namespace NKqp
158-
} // namespace NKikimr
158+
} // namespace NKikimr

ydb/core/kqp/ut/olap/kqp_olap_ut.cpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -5264,7 +5264,7 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
52645264
tableInserter.AddRow().Add(2).Add("test_res_2").Add("val1").AddNull();
52655265
tableInserter.AddRow().Add(3).Add("test_res_3").Add("val3").AddNull();
52665266
tableInserter.AddRow().Add(2).Add("test_res_2").Add("val2").AddNull();
5267-
testHelper.InsertData(testTable, tableInserter);
5267+
testHelper.BulkUpsert(testTable, tableInserter);
52685268
}
52695269
while (csController->GetIndexations().Val() == 0) {
52705270
Cout << "Wait indexation..." << Endl;

ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -5579,7 +5579,7 @@ Y_UNIT_TEST_SUITE(KqpOlapScheme) {
55795579
TTestHelper::TUpdatesBuilder tableInserter(testTable.GetArrowSchema(schemaWithNull));
55805580
tableInserter.AddRow().Add(1).Add("test_res_1").AddNull();
55815581
tableInserter.AddRow().Add(2).Add("test_res_2").Add(123);
5582-
testHelper.BulkUpsert(testTable, tableInserter, {}, Ydb::StatusIds::GENERIC_ERROR);
5582+
testHelper.BulkUpsert(testTable, tableInserter, Ydb::StatusIds::GENERIC_ERROR);
55835583
}
55845584
{
55855585
TTestHelper::TUpdatesBuilder tableInserter(testTable.GetArrowSchema(schemaWithNull));

0 commit comments

Comments
 (0)