aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorSemyon <yentsovsemyon@ydb.tech>2025-02-10 21:11:32 +0300
committerGitHub <noreply@github.com>2025-02-10 21:11:32 +0300
commit4878da3dd9b3b683b5420c7dbb403fe035ff74cd (patch)
tree7a4d4018347a60c085a51a03cfd102feed82416e
parente9ffe2e260af75c267b1c80464033258bd53a231 (diff)
downloadydb-4878da3dd9b3b683b5420c7dbb403fe035ff74cd.tar.gz
fix arrow schema in tests (#14331)
-rw-r--r--ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp5
-rw-r--r--ydb/core/testlib/cs_helper.cpp4
2 files changed, 2 insertions, 7 deletions
diff --git a/ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp b/ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp
index 459c60dcce..6fe2f3a677 100644
--- a/ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp
+++ b/ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp
@@ -12079,11 +12079,6 @@ Y_UNIT_TEST_SUITE(KqpOlapTypes) {
tableInserter.AddRow().Add(2).Add(jsonString).Add(jsonBin);
testHelper.BulkUpsert(testTable, tableInserter);
}
- {
- TTestHelper::TUpdatesBuilder tableInserter(testTable.GetArrowSchema(schema));
- tableInserter.AddRow().Add(3).Add(jsonBin).AddNull();
- testHelper.BulkUpsert(testTable, tableInserter, Ydb::StatusIds::SCHEME_ERROR);
- }
}
}
diff --git a/ydb/core/testlib/cs_helper.cpp b/ydb/core/testlib/cs_helper.cpp
index 0c187e4d80..429b464bba 100644
--- a/ydb/core/testlib/cs_helper.cpp
+++ b/ydb/core/testlib/cs_helper.cpp
@@ -450,7 +450,7 @@ std::shared_ptr<arrow::RecordBatch> TTableWithNullsHelper::TestArrowBatch(ui64,
arrow::Int32Builder bId;
arrow::StringBuilder bResourceId;
arrow::Int32Builder bLevel;
- arrow::StringBuilder bBinaryStr;
+ arrow::BinaryBuilder bBinaryStr;
arrow::StringBuilder bJsonVal;
arrow::BinaryBuilder bJsonDoc;
@@ -476,7 +476,7 @@ std::shared_ptr<arrow::RecordBatch> TTableWithNullsHelper::TestArrowBatch(ui64,
std::shared_ptr<arrow::Int32Array> aId;
std::shared_ptr<arrow::StringArray> aResourceId;
std::shared_ptr<arrow::Int32Array> aLevel;
- std::shared_ptr<arrow::StringArray> aBinaryStr;
+ std::shared_ptr<arrow::BinaryArray> aBinaryStr;
std::shared_ptr<arrow::StringArray> aJsonVal;
std::shared_ptr<arrow::BinaryArray> aJsonDoc;