fix: check version before alter region

GreptimeTeam · Sep 18, 2023 · 39e0e11 · 39e0e11
1 parent c42cce5
commit 39e0e11
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/src/mito2/src/worker/handle_alter.rs b/src/mito2/src/worker/handle_alter.rs
@@ -47,6 +47,19 @@ impl<S> RegionWorkerLoop<S> {
 
         // Get the version before alter.
         let version = region.version();
+<<<<<<< Updated upstream
+        if version.metadata.schema_version >= request.schema_version {
+=======
+        if version.metadata.schema_version > request.schema_version {
+            warn!(
+                "region schema version {} greater than request schema version {}",
+                version.metadata.schema_version, request.schema_version
+            );
+>>>>>>> Stashed changes
+            // Returns if it altered.
+            sender.send(Ok(Output::AffectedRows(0)));
+            return;
+        }
         // Checks whether we can alter the region directly.
         if !version.memtables.is_empty() {
             // If memtable is not empty, we can't alter it directly and need to flush