diff --git a/fe/fe-core/src/main/java/org/apache/doris/backup/BackupJobInfo.java b/fe/fe-core/src/main/java/org/apache/doris/backup/BackupJobInfo.java index fff2b755c1..a199aca7c3 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/backup/BackupJobInfo.java +++ b/fe/fe-core/src/main/java/org/apache/doris/backup/BackupJobInfo.java @@ -33,6 +33,7 @@ import org.apache.doris.catalog.TableIf.TableType; import org.apache.doris.catalog.Tablet; import org.apache.doris.catalog.View; import org.apache.doris.common.FeConstants; +import org.apache.doris.common.Version; import org.apache.doris.common.io.Text; import org.apache.doris.common.io.Writable; import org.apache.doris.persist.gson.GsonUtils; @@ -92,6 +93,12 @@ public class BackupJobInfo implements Writable { @SerializedName("meta_version") public int metaVersion; + @SerializedName("major_version") + public int majorVersion; + @SerializedName("minor_version") + public int minorVersion; + @SerializedName("patch_version") + public int patchVersion; @SerializedName("tablet_be_map") public Map tabletBeMap = Maps.newHashMap(); @@ -588,6 +595,9 @@ public class BackupJobInfo implements Writable { jobInfo.metaVersion = FeConstants.meta_version; jobInfo.content = content; jobInfo.tableCommitSeqMap = tableCommitSeqMap; + jobInfo.majorVersion = Version.DORIS_BUILD_VERSION_MAJOR; + jobInfo.minorVersion = Version.DORIS_BUILD_VERSION_MINOR; + jobInfo.patchVersion = Version.DORIS_BUILD_VERSION_PATCH; Collection tbls = backupMeta.getTables().values(); // tbls