This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch TooManyOpenFiles in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 63e446b866ecab7bae41b0d44b260152d7105e6b Author: JackieTien97 <[email protected]> AuthorDate: Tue Jan 18 14:03:20 2022 +0800 add synchronize --- pom.xml | 2 +- .../main/java/org/apache/iotdb/db/query/control/FileReaderManager.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pom.xml b/pom.xml index a293331..bf52818 100644 --- a/pom.xml +++ b/pom.xml @@ -109,7 +109,7 @@ <module>client-cpp</module> <module>metrics</module> <module>integration</module> -<!-- <module>library-udf</module>--> + <!-- <module>library-udf</module>--> </modules> <!-- Properties Management --> <properties> 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 fb8f1bb..9be04e3 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 @@ -235,7 +235,7 @@ public class FileReaderManager { || (!isClosed && unclosedFileReaderMap.containsKey(tsFile.getTsFilePath())); } - public void writeFileReferenceInfo() { + public synchronized void writeFileReferenceInfo() { DEBUG_LOGGER.info("[closedReferenceMap]\n"); for (Map.Entry<String, AtomicInteger> entry : closedReferenceMap.entrySet()) { DEBUG_LOGGER.info(String.format("\t%s: %d\n", entry.getKey(), entry.getValue().get()));
