diff options
author | snaury <[email protected]> | 2023-10-18 17:49:49 +0300 |
---|---|---|
committer | snaury <[email protected]> | 2023-10-18 18:45:52 +0300 |
commit | c818a211e33e13006af5e69d2167a6b5390b11f8 (patch) | |
tree | 3d758db1b90dcd9d055c0ae0d07da1c5594f0769 | |
parent | c46d729241c1f3a162e4d5a575d8245f3c7c4a9a (diff) |
Fix importing multiple converted csv columns KIKIMR-19751
-rw-r--r-- | ydb/core/formats/arrow/converter.cpp | 2 |
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 |