This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a commit to branch improve_wal
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/improve_wal by this push:
new 053fc5d merge add restart logs
053fc5d is described below
commit 053fc5db09303a00532f7c15e9277ae78c366dd5
Author: jt <[email protected]>
AuthorDate: Tue Oct 13 12:50:32 2020 +0800
merge add restart logs
---
.../src/main/java/org/apache/iotdb/tsfile/write/page/PageWriter.java | 4 ++--
.../java/org/apache/iotdb/tsfile/write/writer/TsFileIOWriter.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/page/PageWriter.java
b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/page/PageWriter.java
index 6fef893..ba8001a 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/page/PageWriter.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/page/PageWriter.java
@@ -258,7 +258,7 @@ public class PageWriter {
header.serializeTo(pageBuffer);
// write page content to temp PBAOS
- logger.debug("start to flush a page data into buffer, buffer position {}
", pageBuffer.size());
+ logger.trace("start to flush a page data into buffer, buffer position {}
", pageBuffer.size());
if (compressor.getType().equals(CompressionType.UNCOMPRESSED)) {
try (WritableByteChannel channel = Channels.newChannel(pageBuffer)) {
channel.write(pageData);
@@ -266,7 +266,7 @@ public class PageWriter {
} else {
pageBuffer.write(compressedBytes, compressedPosition, compressedSize);
}
- logger.debug("start to flush a page data into buffer, buffer position {}
", pageBuffer.size());
+ logger.trace("start to flush a page data into buffer, buffer position {}
", pageBuffer.size());
}
/**
diff --git
a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/writer/TsFileIOWriter.java
b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/writer/TsFileIOWriter.java
index 7ad89b2..cf6c04d 100644
---
a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/writer/TsFileIOWriter.java
+++
b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/writer/TsFileIOWriter.java
@@ -142,8 +142,8 @@ public class TsFileIOWriter {
public void startChunkGroup(String deviceId) throws IOException {
this.currentChunkGroupDeviceId = deviceId;
currentChunkGroupStartOffset = out.getPosition();
- if (logger.isDebugEnabled()) {
- logger.debug("start chunk group:{}, file position {}", deviceId,
out.getPosition());
+ if (logger.isTraceEnabled()) {
+ logger.trace("start chunk group:{}, file position {}", deviceId,
out.getPosition());
}
chunkMetadataList = new ArrayList<>();
}