File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed
dbms/src/Storages/DeltaMerge/VersionChain Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change @@ -81,7 +81,12 @@ UInt32 buildDeleteMarkFilterDMFile(
81
81
if (!rs_results[i].isUse ())
82
82
continue ;
83
83
84
- if (pack_properties.property (pack_id).deleted_rows () > 0 )
84
+ // deleted_rows is added after v6.1.
85
+ // For compatibility purposes, if either pack_properties is missing or deleted_rows is unavailable,
86
+ // the delmark data must be read and used for filtering.
87
+ if (static_cast <UInt32>(pack_properties.property_size ()) <= pack_id
88
+ || !pack_properties.property (pack_id).has_deleted_rows ()
89
+ || pack_properties.property (pack_id).deleted_rows () > 0 )
85
90
{
86
91
need_read_packs->insert (pack_id);
87
92
start_row_id_of_need_read_packs.emplace (pack_id, pack_start_row_id);
You can’t perform that action at this time.
0 commit comments