diff --git a/service-common/src/main/java/com/lanyuanxiaoyao/service/common/Constants.java b/service-common/src/main/java/com/lanyuanxiaoyao/service/common/Constants.java index 37c3a16..4849988 100644 --- a/service-common/src/main/java/com/lanyuanxiaoyao/service/common/Constants.java +++ b/service-common/src/main/java/com/lanyuanxiaoyao/service/common/Constants.java @@ -186,6 +186,7 @@ public interface Constants { String LOG_POINT_FIELD_TYPE_NOT_FOUND = LOG_POINT_PREFIX + "000006"; String TAGS_NO_COMPACT = "NO_COMPACT"; + String TAGS_NO_SCHEDULE_COMPACT = "NO_SCHEDULE_COMPACT"; String TAGS_PULSAR_BACKUP = "PULSAR_BACKUP"; String TAGS_NO_PRE_COMBINE = "NO_PRE_COMBINE"; String TAGS_PRE_COMBINE = "PRE_COMBINE"; diff --git a/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/utils/ScheduleHelper.java b/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/utils/ScheduleHelper.java index 5394748..c6b8539 100644 --- a/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/utils/ScheduleHelper.java +++ b/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/utils/ScheduleHelper.java @@ -72,6 +72,8 @@ public class ScheduleHelper { }) // 拒绝不压缩标志的任务 .reject(meta -> TableMetaHelper.existsTag(meta, Constants.TAGS_NO_COMPACT)) + // 拒绝不调度压缩标志的任务 + .reject(meta -> TableMetaHelper.existsTag(meta, Constants.TAGS_NO_SCHEDULE_COMPACT)) .collect(meta -> { long compactionDuration = 0L; try { diff --git a/service-web/src/main/resources/static/components/common.js b/service-web/src/main/resources/static/components/common.js index 72543d2..543e81a 100644 --- a/service-web/src/main/resources/static/components/common.js +++ b/service-web/src/main/resources/static/components/common.js @@ -1889,6 +1889,7 @@ let compactionStatusMapping = [ let tagsMapping = [ mappingItem('不压缩', 'NO_COMPACT'), + mappingItem('不调度压缩', 'NO_SCHEDULE_COMPACT'), mappingItem('备份Pulsar消息', 'PULSAR_BACKUP'), mappingItem('无预合并', 'NO_PRE_COMBINE'), mappingItem('不忽略写日志错误', 'NO_IGNORE_FAILED'),