thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-18 13:42:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

rebase main

Browse Source
This commit is contained in:
kevinyhzou 2023-07-14 11:24:38 +08:00
parent b2665031dc
commit c6b8097090
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Processors/Formats/Impl/CSVRowInputFormat.cpp
View File

@ -329,7 +329,7 @@ bool CSVFormatReader::readField(
SerializationNullable::deserializeTextCSVImpl(column, tmp, format_settings, serialization);
else
serialization->deserializeTextCSV(column, tmp, format_settings);
if (column.size() == col_size + 1 && field.size() > 0 && !tm.eof())
if (column.size() == col_size + 1 && field.size() > 0 && !tmp.eof())
throw Exception(ErrorCodes::LOGICAL_ERROR, "Text CSV deserialize field bytes logical error.");
}
else
@ -346,7 +346,7 @@ bool CSVFormatReader::readField(
catch (Exception & e)
{
LOG_DEBUG(&Poco::Logger::get("CSVRowInputFormat"), "Failed to deserialize CSV column, exception message:{}", e.what());
if (format_settings.csv.allow_set_column_default_value_if_deserialize_failed)
if (format_settings.csv.set_default_if_deserialize_failed)
{
// Reset the column and buffer position, then skip the field and set column default value.
if (column.size() == col_size + 1)