diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java index 0e2243036c..4066b58775 100755 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java @@ -1773,6 +1773,12 @@ public class Env { public long loadHeaderCOR1(DataInputStream dis, long checksum) throws IOException { int journalVersion = dis.readInt(); + if (journalVersion > FeMetaVersion.VERSION_CURRENT) { + throw new IOException("The meta version of image is " + journalVersion + + ", which is higher than FE current version " + FeMetaVersion.VERSION_CURRENT + + ". Please upgrade your cluster to the latest version first."); + } + long newChecksum = checksum ^ journalVersion; MetaContext.get().setMetaVersion(journalVersion);