diff --git a/be/src/olap/rowset/segment_v2/inverted_index_writer.cpp b/be/src/olap/rowset/segment_v2/inverted_index_writer.cpp index 718d46f5e2bb243..2d7fc33bb1e5cd6 100644 --- a/be/src/olap/rowset/segment_v2/inverted_index_writer.cpp +++ b/be/src/olap/rowset/segment_v2/inverted_index_writer.cpp @@ -304,6 +304,9 @@ class InvertedIndexColumnWriterImpl : public InvertedIndexColumnWriter { << "value length:" << v->get_size() << ", ignore this value"; new_fulltext_field(empty_value.c_str(), 0); RETURN_IF_ERROR(add_null_document()); + } else if (_parser_type != InvertedIndexParserType::PARSER_NONE && v->empty()) { + new_fulltext_field(empty_value.c_str(), 0); + RETURN_IF_ERROR(add_null_document()); } else { new_fulltext_field(v->get_data(), v->get_size()); RETURN_IF_ERROR(add_document()); @@ -354,6 +357,9 @@ class InvertedIndexColumnWriterImpl : public InvertedIndexColumnWriter { << "value length:" << value.length() << ", ignore this value"; new_fulltext_field(empty_value.c_str(), 0); RETURN_IF_ERROR(add_null_document()); + } else if (_parser_type != InvertedIndexParserType::PARSER_NONE && v->empty()) { + new_fulltext_field(empty_value.c_str(), 0); + RETURN_IF_ERROR(add_null_document()); } else { new_fulltext_field(value.c_str(), value.length()); RETURN_IF_ERROR(add_document());