chaoyli commented on a change in pull request #4011:
URL: https://github.com/apache/incubator-doris/pull/4011#discussion_r449348960
##########
File path: be/src/olap/tablet.cpp
##########
@@ -826,6 +832,33 @@ void Tablet::_print_missed_versions(const
std::vector<Version>& missed_versions)
LOG(WARNING) << ss.str();
}
+bool Tablet::_drop_rowset_if_version_conflict(const RowsetSharedPtr& rowset) {
Review comment:
There has a problem in this place.
modify_rowsets() only change the TabletMeta in memory. But not change the
meta in disk.
So you should perform do_tablet_meta_checkpoint to save the meta and remove
the rowsetmeta in RowsetMetaManager.
##########
File path: be/src/olap/tablet.cpp
##########
@@ -826,6 +832,33 @@ void Tablet::_print_missed_versions(const
std::vector<Version>& missed_versions)
LOG(WARNING) << ss.str();
}
+bool Tablet::_drop_rowset_if_version_conflict(const RowsetSharedPtr& rowset) {
+ if (rowset == nullptr) {
+ return false;
+ }
+ Version insert_version = {rowset->start_version(), rowset->end_version()};
+ Version max_version = _tablet_meta->max_version();
+ if (insert_version != max_version) {
+ return false;
+ }
+
+ RowsetSharedPtr exist_rs = get_rowset_by_version(insert_version);
+ // if a rs is created by doris 0.10 exists, remove it.
+ if (exist_rs != nullptr) {
+ vector<RowsetSharedPtr> to_add;
+ vector<RowsetSharedPtr> to_delete;
+ to_delete.push_back(exist_rs);
+ modify_rowsets(to_add, to_delete);
+ std::stringstream ss;
+ ss << "Remove rs " << exist_rs->rowset_id().to_string();
Review comment:
LOG(WARNING) << "Remove rs " << exist_rs->rowset_id().to_string()
<< " in " << full_name()
<< " for version conflict with " <<
rowset->rowset_id().to_string()
There is no necessity to use std::stringstream.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
