You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2020/11/10 05:50:04 UTC
[iotdb] branch rel/0.11 updated: stop print query frequency if no
query happened (#1994)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch rel/0.11
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/rel/0.11 by this push:
new 0ff7fa8 stop print query frequency if no query happened (#1994)
0ff7fa8 is described below
commit 0ff7fa84d21da49ba4c618dd3ba4a5c0c536eb6e
Author: Jackie Tien <Ja...@foxmail.com>
AuthorDate: Tue Nov 10 13:47:47 2020 +0800
stop print query frequency if no query happened (#1994)
---
.../main/java/org/apache/iotdb/db/service/TSServiceImpl.java | 11 ++++++++---
1 file changed, 8 insertions(+), 3 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
index 22eae33..2e4c247 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
@@ -199,8 +199,12 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext {
ScheduledExecutorService timedQuerySqlCountThread = Executors
.newSingleThreadScheduledExecutor(r -> new Thread(r, "timedQuerySqlCountThread"));
- timedQuerySqlCountThread.scheduleAtFixedRate(() -> QUERY_FREQUENCY_LOGGER
- .info("Query count in current 1 minute: " + queryCount.getAndSet(0)),
+ timedQuerySqlCountThread.scheduleAtFixedRate(() -> {
+ if (queryCount.get() != 0) {
+ QUERY_FREQUENCY_LOGGER
+ .info("Query count in current 1 minute: " + queryCount.getAndSet(0));
+ }
+ },
config.getFrequencyIntervalInMinute(), config.getFrequencyIntervalInMinute(),
TimeUnit.MINUTES);
}
@@ -252,7 +256,8 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext {
} else {
tsStatus = RpcUtils.getStatus(TSStatusCode.WRONG_LOGIN_PASSWORD_ERROR,
loginMessage != null ? loginMessage : "Authentication failed.");
- auditLogger.info("User {} opens Session failed with an incorrect password", req.getUsername());
+ auditLogger
+ .info("User {} opens Session failed with an incorrect password", req.getUsername());
}
TSOpenSessionResp resp = new TSOpenSessionResp(tsStatus,
CURRENT_RPC_VERSION);