diff --git a/dbms/src/Storages/Tantivy/TantivyInputStream.h b/dbms/src/Storages/Tantivy/TantivyInputStream.h index 97f94cf7fca..4f365a3dfe8 100644 --- a/dbms/src/Storages/Tantivy/TantivyInputStream.h +++ b/dbms/src/Storages/Tantivy/TantivyInputStream.h @@ -50,6 +50,8 @@ class TantivyInputStream : public IProfilingBlockInputStream { static constexpr auto NAME = "TantivyInputStream"; + static constexpr auto version_column_name = "column_-1024"; + public: TantivyInputStream( LoggerPtr log_, @@ -142,6 +144,15 @@ class TantivyInputStream : public IProfilingBlockInputStream } if (idx == -1) { + if (name_and_type.name == version_column_name) + { + auto col = res.getByName(name_and_type.name).column->assumeMutable(); + for (auto & doc : documents) + { + col->insert(Field(doc.version)); + } + continue; + } for (size_t j = 0; j < documents.size(); j++) { // Insert default value for missing fields