Time to update cleanup statistics (#175)
### Motivation
Currently, the time unit for collecting statistics is milliseconds, and the configuration file is incorrect
### Modifications
* Unify units so that units for collecting and clearing statistical information become milliseconds.
diff --git a/src/main/java/io/streamnative/pulsar/manager/service/impl/BrokerStatsServiceImpl.java b/src/main/java/io/streamnative/pulsar/manager/service/impl/BrokerStatsServiceImpl.java
index a03d052..592c5d9 100644
--- a/src/main/java/io/streamnative/pulsar/manager/service/impl/BrokerStatsServiceImpl.java
+++ b/src/main/java/io/streamnative/pulsar/manager/service/impl/BrokerStatsServiceImpl.java
@@ -130,7 +130,7 @@
});
log.info("Start clearing stats from broker");
- clearStats(unixTime, clearStatsInterval);
+ clearStats(unixTime, clearStatsInterval / 1000);
}
public void collectStatsToDB(long unixTime, String env, String cluster, String serviceUrl) {
diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
index 1141d6f..173d2ea 100644
--- a/src/main/resources/application.properties
+++ b/src/main/resources/application.properties
@@ -57,7 +57,9 @@
redirect.port=9527
# Stats interval
+# millisecond
insert.stats.interval=30000
+# millisecond
clear.stats.interval=300000
init.delay.interval=0
