diff options
| author | Semyon <yentsovsemyon@ydb.tech> | 2025-02-10 21:11:32 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-02-10 21:11:32 +0300 |
| commit | 4878da3dd9b3b683b5420c7dbb403fe035ff74cd (patch) | |
| tree | 7a4d4018347a60c085a51a03cfd102feed82416e | |
| parent | e9ffe2e260af75c267b1c80464033258bd53a231 (diff) | |
| download | ydb-4878da3dd9b3b683b5420c7dbb403fe035ff74cd.tar.gz | |
fix arrow schema in tests (#14331)
| -rw-r--r-- | ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp | 5 | ||||
| -rw-r--r-- | ydb/core/testlib/cs_helper.cpp | 4 |
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; |