You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/01/19 01:45:06 UTC
[iotdb] branch WarningLog012 updated: format code
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch WarningLog012
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/WarningLog012 by this push:
new 68ac637 format code
68ac637 is described below
commit 68ac637b4668f85ab8429e36ecc56688d64297ba
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Wed Jan 19 09:42:40 2022 +0800
format code
---
.../java/org/apache/iotdb/db/query/control/FileReaderManager.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/query/control/FileReaderManager.java b/server/src/main/java/org/apache/iotdb/db/query/control/FileReaderManager.java
index eae61c5..9badbf9 100644
--- a/server/src/main/java/org/apache/iotdb/db/query/control/FileReaderManager.java
+++ b/server/src/main/java/org/apache/iotdb/db/query/control/FileReaderManager.java
@@ -46,7 +46,8 @@ public class FileReaderManager {
private static final int MAX_CACHED_FILE_SIZE = 30000;
/**
- * When number of file streams reached MAX_CACHED_FILE_SIZE, then we will print a warning log each PRINT_INTERVAL
+ * When number of file streams reached MAX_CACHED_FILE_SIZE, then we will print a warning log each
+ * PRINT_INTERVAL
*/
private static final int PRINT_INTERVAL = 10000;
@@ -114,7 +115,8 @@ public class FileReaderManager {
!isClosed ? unclosedFileReaderMap : closedFileReaderMap;
if (!readerMap.containsKey(filePath)) {
int currentOpenedReaderCount = readerMap.size();
- if (currentOpenedReaderCount >= MAX_CACHED_FILE_SIZE && (currentOpenedReaderCount % PRINT_INTERVAL == 0)) {
+ if (currentOpenedReaderCount >= MAX_CACHED_FILE_SIZE
+ && (currentOpenedReaderCount % PRINT_INTERVAL == 0)) {
logger.warn("Query has opened {} files !", readerMap.size());
}