version & fix checkstyle

pull/1435/head
shedfreewu 1 year ago
parent 8d82056737
commit 432d615205

@ -54,10 +54,12 @@ public class LosslessConfigModifier implements PolarisConfigModifier {
if (Objects.nonNull(losslessProperties.getHealthCheckInterval())) { if (Objects.nonNull(losslessProperties.getHealthCheckInterval())) {
losslessConfig.setHealthCheckInterval(losslessProperties.getHealthCheckInterval()); losslessConfig.setHealthCheckInterval(losslessProperties.getHealthCheckInterval());
} }
} else { }
else {
losslessConfig.setStrategy(LosslessProto.DelayRegister.DelayStrategy.DELAY_BY_TIME); losslessConfig.setStrategy(LosslessProto.DelayRegister.DelayStrategy.DELAY_BY_TIME);
} }
} else { }
else {
losslessConfig.setEnable(false); losslessConfig.setEnable(false);
} }
} }

@ -49,12 +49,13 @@ public class WarmupConfigModifier implements PolarisConfigModifier {
Set<String> chainSet = new TreeSet<>( Set<String> chainSet = new TreeSet<>(
Optional.ofNullable(weightAdjustConfig.getChain()).orElse(Collections.emptyList())); Optional.ofNullable(weightAdjustConfig.getChain()).orElse(Collections.emptyList()));
chainSet.add(WarmupWeightAdjuster.WARMUP_WEIGHT_ADJUSTER_NAME); chainSet.add(WarmupWeightAdjuster.WARMUP_WEIGHT_ADJUSTER_NAME);
weightAdjustConfig.setChain(new ArrayList<>(chainSet)); weightAdjustConfig.setChain(new ArrayList<>(chainSet));
} else { }
else {
Set<String> chainSet = new TreeSet<>( Set<String> chainSet = new TreeSet<>(
Optional.ofNullable(weightAdjustConfig.getChain()).orElse(Collections.emptyList())); Optional.ofNullable(weightAdjustConfig.getChain()).orElse(Collections.emptyList()));
chainSet.remove(WarmupWeightAdjuster.WARMUP_WEIGHT_ADJUSTER_NAME); chainSet.remove(WarmupWeightAdjuster.WARMUP_WEIGHT_ADJUSTER_NAME);
weightAdjustConfig.setChain(new ArrayList<>(chainSet)); weightAdjustConfig.setChain(new ArrayList<>(chainSet));
} }
} }

Loading…
Cancel
Save