feat(scheduler): 增加表可以不进行压缩调度但可以进行手动压缩
This commit is contained in:
@@ -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";
|
||||
|
||||
@@ -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 {
|
||||
|
||||
@@ -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'),
|
||||
|
||||
Reference in New Issue
Block a user