From e9d045b04e122310b77df8cd2522bca3147249d7 Mon Sep 17 00:00:00 2001 From: yinjiangyi Date: Mon, 16 Aug 2021 15:58:56 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9E=E9=99=85=E9=83=A8=E7=BD=B2=E7=8E=AF?= =?UTF-8?q?=E5=A2=83=E9=85=8D=E7=BD=AE=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/cn/mesalab/service/BaselineSingleThread.java | 7 +++---- src/main/resources/application.properties | 4 ++-- 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/src/main/java/cn/mesalab/service/BaselineSingleThread.java b/src/main/java/cn/mesalab/service/BaselineSingleThread.java index 719f862..af4e2ec 100644 --- a/src/main/java/cn/mesalab/service/BaselineSingleThread.java +++ b/src/main/java/cn/mesalab/service/BaselineSingleThread.java @@ -126,10 +126,6 @@ public class BaselineSingleThread extends Thread { return readFromDruid; } - /** - * - * @return baseline序列，长度为 60/HISTORICAL_GRAD*24 - */ /** * 单ip baseline生成逻辑 * @param ip @@ -166,12 +162,14 @@ public class BaselineSingleThread extends Thread { } // KF baselineArr = baselineFunction(series); + System.out.println("type-01：" + ip + " " + Arrays.toString(baselineArr)); } else { // 判断周期性 if (SeriesUtils.isPeriod(series)){ baselineGenerationType = 2; // KF baselineArr = baselineFunction(series); + System.out.println("type-02：" + ip + " " + Arrays.toString(baselineArr)); } else { baselineGenerationType = 3; // 百分位数 @@ -180,6 +178,7 @@ public class BaselineSingleThread extends Thread { Integer.valueOf(i.get(ApplicationConfig.BASELINE_METRIC_TYPE).toString())).collect(Collectors.toList()), ApplicationConfig.BASELINE_RATIONAL_PERCENTILE); Arrays.fill(baselineArr, ipPercentile); +// System.out.println("type-03：" + ip + " " + Arrays.toString(baselineArr)); } } diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties index 52026dc..f062d1c 100644 --- a/src/main/resources/application.properties +++ b/src/main/resources/application.properties @@ -2,13 +2,13 @@ ############## 数据库配置 ############### ########################################## #Druid配置 -druid.url=jdbc:avatica:remote:url=http://192.168.44.12:8082/druid/v2/sql/avatica/ +druid.url=jdbc:avatica:remote:url=http://192.168.44.10:8082/druid/v2/sql/avatica/ druid.driver=org.apache.calcite.avatica.remote.Driver druid.table=traffic_top_destination_ip_metrics_log #HBase配置 hbase.table=ddos_traffic_baselines -hbase.zookeeper.quorum=192.168.44.12 +hbase.zookeeper.quorum=192.168.44.11 hbase.zookeeper.client.port=2181 ##########################################