This is an automated email from the ASF dual-hosted git repository. morningman pushed a commit to branch branch-1.2-lts in repository https://gitbox.apache.org/repos/asf/doris.git
commit b2f45a0e9788fa65a53d36b3743bdf26649ed69a Author: Mingyu Chen <[email protected]> AuthorDate: Mon Apr 10 18:37:27 2023 +0800 [minor](fe) ignore expired alter job when replay, to save memory (#18508) Skip expired alter job when replay --- fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java | 4 ++++ 1 file changed, 4 insertions(+) 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 11cbd9aaaa..970d86584d 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 @@ -1841,6 +1841,10 @@ public class Env { newChecksum ^= size; for (int i = 0; i < size; i++) { AlterJobV2 alterJobV2 = AlterJobV2.read(dis); + if (alterJobV2.isExpire()) { + LOG.info("alter job {} is expired, type: {}, ignore it", alterJobV2.getJobId(), alterJobV2.getType()); + continue; + } if (type == JobType.ROLLUP || type == JobType.SCHEMA_CHANGE) { if (type == JobType.ROLLUP) { this.getMaterializedViewHandler().addAlterJobV2(alterJobV2); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
