diff --git a/src/main/java/cn/mesalab/service/BaselineSingleThread.java b/src/main/java/cn/mesalab/service/BaselineSingleThread.java index 26a0983..329bcde 100644 --- a/src/main/java/cn/mesalab/service/BaselineSingleThread.java +++ b/src/main/java/cn/mesalab/service/BaselineSingleThread.java @@ -143,21 +143,24 @@ public class BaselineSingleThread extends Thread { if (ipDruidData.size()==0){ return null; } - List originSeries = ipDruidData.stream().map(i -> Integer.valueOf(i.get(ApplicationConfig.BASELINE_METRIC_TYPE).toString())).collect(Collectors.toList()); if(Collections.max(originSeries)==0){ return null; } - int baselineGenerationType = 0; + int ipPercentile = SeriesUtils.percentile(originSeries, ApplicationConfig.BASELINE_RATIONAL_PERCENTILE); + if(ipPercentile == 0){ + LOG.error(ip + "-" + "IP zero-replace value is 0 !"); + } + + int baselineGenerationType; int[] baselineArr = new int[baselinePointNum]; // 时间序列缺失值补0 List> completSeries = SeriesUtils.complementSeries(ipDruidData); Listseries = completSeries.stream().map( i -> Integer.valueOf(i.get(ApplicationConfig.BASELINE_METRIC_TYPE).toString())).collect(Collectors.toList()); - int ipPercentile = SeriesUtils.percentile(originSeries, ApplicationConfig.BASELINE_RATIONAL_PERCENTILE); // 判断ip出现频率 float ipFrequency = ipDruidData.size() / (float) completSeries.size(); diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties index 24b01c6..cb915b5 100644 --- a/src/main/resources/application.properties +++ b/src/main/resources/application.properties @@ -36,7 +36,7 @@ baseline.metric.type=session_rate #Hbase字段映射 hbase.baseline.generation.type.suffix=baseline_type -hbase.baseline.zero.replace.value.suffix=zero_replace_value +hbase.baseline.zero.replace.value.suffix=default_value #数据情况 #读取历史N天数据,最小值为3天(需要判断周期性)