summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorsnaury <[email protected]>2023-10-18 17:49:49 +0300
committersnaury <[email protected]>2023-10-18 18:45:52 +0300
commitc818a211e33e13006af5e69d2167a6b5390b11f8 (patch)
tree3d758db1b90dcd9d055c0ae0d07da1c5594f0769
parentc46d729241c1f3a162e4d5a575d8245f3c7c4a9a (diff)
Fix importing multiple converted csv columns KIKIMR-19751
-rw-r--r--ydb/core/formats/arrow/converter.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/core/formats/arrow/converter.cpp b/ydb/core/formats/arrow/converter.cpp
index 7b4d38ba962..d832275dcf5 100644
--- a/ydb/core/formats/arrow/converter.cpp
+++ b/ydb/core/formats/arrow/converter.cpp
@@ -275,7 +275,6 @@ bool TArrowToYdbConverter::Process(const arrow::RecordBatch& batch, TString& err
}
if (NeedDataConversion(colType)) {
- memPool.Clear();
for (i32 i = 0; i < unroll; ++i) {
if (!ConvertData(cells[i][col], colType, memPool, errorMessage)) {
return false;
@@ -289,6 +288,7 @@ bool TArrowToYdbConverter::Process(const arrow::RecordBatch& batch, TString& err
for (i32 i = 0; i < unroll; ++i) {
RowWriter_.AddRow(cells[i]);
}
+ memPool.Clear();
}
cells.resize(1);
#else