[DNM]

apache · Nov 22, 2024 · 036198d · 036198d
1 parent 1ffecfd
commit 036198d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/be/src/cloud/cloud_schema_change_job.cpp b/be/src/cloud/cloud_schema_change_job.cpp
@@ -119,7 +119,7 @@ Status CloudSchemaChangeJob::process_alter_tablet(const TAlterTabletReqV2& reque
     }
     if (request.alter_version > 1) {
         // [0-1] is a placeholder rowset, no need to convert
-        RETURN_IF_ERROR(_base_tablet->capture_rs_readers({2, start_resp.alter_version()},
+        RETURN_IF_ERROR(_base_tablet->capture_rs_readers({0, start_resp.alter_version()},
                                                          &rs_splits, false));
     }
     Defer defer {[&]() {
@@ -364,7 +364,7 @@ Status CloudSchemaChangeJob::_convert_historical_rowsets(const SchemaChangeParam
         // bitmaps, otherwise we will miss the delete bitmaps of incremental rowsets
         int64_t start_calc_delete_bitmap_version =
                 // [0-1] is a placeholder rowset, start from 2.
-                already_exist_any_version ? 2 : sc_job->alter_version() + 1;
+                already_exist_any_version ? 0 : sc_job->alter_version() + 1;
         RETURN_IF_ERROR(_process_delete_bitmap(sc_job->alter_version(),
                                                start_calc_delete_bitmap_version, initiator));
         sc_job->set_delete_bitmap_lock_initiator(initiator);