You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2019/04/18 14:35:40 UTC
[incubator-iotdb] branch add_disabled_mem_control updated: fix
initialized isClose
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a commit to branch add_disabled_mem_control
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/add_disabled_mem_control by this push:
new 0c38c48 fix initialized isClose
0c38c48 is described below
commit 0c38c48d3b139fbf7681d83dfef1b8cca983f99a
Author: 江天 <jt...@163.com>
AuthorDate: Thu Apr 18 22:34:20 2019 +0800
fix initialized isClose
---
.../org/apache/iotdb/db/engine/bufferwrite/BufferWriteProcessor.java | 2 +-
.../java/org/apache/iotdb/db/engine/overflow/io/OverflowProcessor.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/engine/bufferwrite/BufferWriteProcessor.java b/iotdb/src/main/java/org/apache/iotdb/db/engine/bufferwrite/BufferWriteProcessor.java
index a0932ee..61bfef9 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/engine/bufferwrite/BufferWriteProcessor.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/engine/bufferwrite/BufferWriteProcessor.java
@@ -84,7 +84,7 @@ public class BufferWriteProcessor extends Processor {
private WriteLogNode logNode;
private VersionController versionController;
- private boolean isClosed = false;
+ private boolean isClosed = true;
private boolean isFlush = false;
/**
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/io/OverflowProcessor.java b/iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/io/OverflowProcessor.java
index 1d98d66..7eeb6a3 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/io/OverflowProcessor.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/engine/overflow/io/OverflowProcessor.java
@@ -96,7 +96,7 @@ public class OverflowProcessor extends Processor {
private WriteLogNode logNode;
private VersionController versionController;
- private boolean isClosed = false;
+ private boolean isClosed = true;
private boolean isFlush = false;
public OverflowProcessor(String processorName, Map<String, Action> parameters,