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());
       }