You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hx...@apache.org on 2020/02/22 01:43:43 UTC
[incubator-iotdb] branch new_series_reader_tsfileprocessor_test
updated: fix bug in new log
This is an automated email from the ASF dual-hosted git repository.
hxd pushed a commit to branch new_series_reader_tsfileprocessor_test
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/new_series_reader_tsfileprocessor_test by this push:
new 2a97a15 fix bug in new log
2a97a15 is described below
commit 2a97a15b462524025860896de3763c93298265a9
Author: xiangdong huang <sa...@gmail.com>
AuthorDate: Sat Feb 22 09:43:28 2020 +0800
fix bug in new log
---
server/src/main/java/org/apache/iotdb/db/engine/flush/FlushManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/flush/FlushManager.java b/server/src/main/java/org/apache/iotdb/db/engine/flush/FlushManager.java
index 4dd3ec8..147771e 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/flush/FlushManager.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/flush/FlushManager.java
@@ -107,7 +107,7 @@ public class FlushManager implements FlushManagerMBean, IService {
flushPool.submit(new FlushThread());
} else if (tsFileProcessor.isManagedByFlushManager()){
logger.info("tsFileProcessor {} is already in the flushPool, the first one: {}", tsFileProcessor.getStorageGroupName(),
- tsFileProcessorQueue.getFirst().getStorageGroupName());
+ tsFileProcessorQueue.size() >0 ? tsFileProcessorQueue.getFirst().getStorageGroupName() : "empty now");
} else {
logger.info("No flushing memetable to do, register TsProcessor {} failed.", tsFileProcessor.getStorageGroupName());
}