File tree 1 file changed +7
-0
lines changed
1 file changed +7
-0
lines changed Original file line number Diff line number Diff line change @@ -1544,6 +1544,7 @@ int InstanceRecycler::delete_rowset_data(const std::vector<doris::RowsetMetaClou
1544
1544
// Currently index_ids is guaranteed to be empty,
1545
1545
// but we clear it again here as a safeguard against future code changes
1546
1546
// that might cause index_ids to no longer be empty
1547
+ index_format = InvertedIndexStorageFormatPB::V2;
1547
1548
index_ids.clear ();
1548
1549
} else {
1549
1550
LOG (WARNING) << " failed to get schema kv for rowset, instance_id=" << instance_id_
@@ -1569,6 +1570,12 @@ int InstanceRecycler::delete_rowset_data(const std::vector<doris::RowsetMetaClou
1569
1570
// try to recycle inverted index v2 when get_ret == 1
1570
1571
// we treat schema not found as if it has a v2 format inverted index
1571
1572
// to reduce chance of data leakage
1573
+ if (inverted_index_get_ret == 1 ) {
1574
+ LOG_INFO (" delete rowset data schema kv not found, try to delete index file" )
1575
+ .tag (" instance_id" , instance_id_)
1576
+ .tag (" inverted index v2 path" ,
1577
+ inverted_index_path_v2 (tablet_id, rowset_id, i));
1578
+ }
1572
1579
file_paths.push_back (inverted_index_path_v2 (tablet_id, rowset_id, i));
1573
1580
}
1574
1581
}
You can’t perform that action at this time.
0 commit comments