diff --git a/be/src/vec/exec/format/file_reader/new_plain_text_line_reader.cpp b/be/src/vec/exec/format/file_reader/new_plain_text_line_reader.cpp index 8dce6e589afde2..75350890aee1df 100644 --- a/be/src/vec/exec/format/file_reader/new_plain_text_line_reader.cpp +++ b/be/src/vec/exec/format/file_reader/new_plain_text_line_reader.cpp @@ -160,6 +160,11 @@ void EncloseCsvLineReaderContext::_on_pre_match_enclose(const uint8_t* start, si if (_idx != _total_len) { len = update_reading_bound(start); } else { + // It needs to set the result to nullptr for matching enclose may not be read + // after reading the output buf. + // Therefore, if the result is not set to nullptr, + // the parser will consider reading a line as there is a line delimiter. + _result = nullptr; break; } } while (true);