fix

Signed-off-by: gengjun-git <[email protected]>
StarRocks · Oct 16, 2024 · 3b7f467 · 3b7f467
1 parent 82d5eeb
commit 3b7f467
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/fe/fe-core/src/main/java/com/starrocks/persist/EditLog.java b/fe/fe-core/src/main/java/com/starrocks/persist/EditLog.java
@@ -53,6 +53,7 @@
 import com.starrocks.catalog.MetaVersion;
 import com.starrocks.catalog.Resource;
 import com.starrocks.common.Config;
+import com.starrocks.common.FeConstants;
 import com.starrocks.common.Pair;
 import com.starrocks.common.io.DataOutputBuffer;
 import com.starrocks.common.io.Text;
@@ -486,6 +487,12 @@ public void loadJournal(GlobalStateMgr globalStateMgr, JournalEntity journal)
  break;
  }
  case OperationType.OP_META_VERSION_V2: {
+ MetaVersion metaVersion = (MetaVersion) journal.getData();
+ if (!MetaVersion.isCompatible(metaVersion.getStarRocksVersion(), FeConstants.STARROCKS_META_VERSION)) {
+ throw new JournalInconsistentException("Not compatible with meta version "
+ + metaVersion.getStarRocksVersion()
+ + ", current version is " + FeConstants.STARROCKS_META_VERSION);
+ }
  break;
  }
  case OperationType.OP_ADD_BROKER_V2: {