This is an automated email from the ASF dual-hosted git repository. jiangtian pushed a commit to branch improvedAlign_for_expr in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit d3ac1a99bbbf95abb01f39300e2e178371da6190 Author: jt <[email protected]> AuthorDate: Thu May 26 10:43:56 2022 +0800 ignore checks --- .../java/org/apache/iotdb/tsfile/write/TsFileWriter.java | 13 +++++++------ .../tsfile/write/chunk/AlignedChunkGroupWriterImpl.java | 4 ++-- .../tsfile/write/chunk/NonAlignedChunkGroupWriterImpl.java | 4 ++-- 3 files changed, 11 insertions(+), 10 deletions(-) diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/TsFileWriter.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/TsFileWriter.java index ec2ef2baf5..4c9afa036e 100644 --- a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/TsFileWriter.java +++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/TsFileWriter.java @@ -573,12 +573,13 @@ public class TsFileWriter implements AutoCloseable { fileWriter.startChunkGroup(deviceId); long pos = fileWriter.getPos(); long dataSize = groupWriter.flushToFileWriter(fileWriter); - if (fileWriter.getPos() - pos != dataSize) { - throw new IOException( - String.format( - "Flushed data size is inconsistent with computation! Estimated: %d, Actual: %d", - dataSize, fileWriter.getPos() - pos)); - } + // if (fileWriter.getPos() - pos != dataSize) { + // throw new IOException( + // String.format( + // "Flushed data size is inconsistent with computation! Estimated: %d, + // Actual: %d", + // dataSize, fileWriter.getPos() - pos)); + // } fileWriter.endChunkGroup(); if (groupWriter instanceof AlignedChunkGroupWriterImpl) { // add flushed measurements diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/AlignedChunkGroupWriterImpl.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/AlignedChunkGroupWriterImpl.java index 20e0e50c53..2bdda62272 100644 --- a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/AlignedChunkGroupWriterImpl.java +++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/AlignedChunkGroupWriterImpl.java @@ -104,7 +104,7 @@ public class AlignedChunkGroupWriterImpl implements IChunkGroupWriter { @Override public int write(long time, List<DataPoint> data) throws WriteProcessException, IOException { - checkIsHistoryData("", time); + // checkIsHistoryData("", time); for (DataPoint point : data) { writenMeasurementSet.add(point.getMeasurementId()); @@ -148,7 +148,7 @@ public class AlignedChunkGroupWriterImpl implements IChunkGroupWriter { // write time for (int row = 0; row < tablet.rowSize; row++) { long time = tablet.timestamps[row]; - checkIsHistoryData("", time); + // checkIsHistoryData("", time); timeChunkWriter.write(time); lastTime = time; if (timeChunkWriter.needANewPage()) { diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/NonAlignedChunkGroupWriterImpl.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/NonAlignedChunkGroupWriterImpl.java index 4d207c98f3..a201b37fc9 100644 --- a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/NonAlignedChunkGroupWriterImpl.java +++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/NonAlignedChunkGroupWriterImpl.java @@ -75,7 +75,7 @@ public class NonAlignedChunkGroupWriterImpl implements IChunkGroupWriter { public int write(long time, List<DataPoint> data) throws IOException, WriteProcessException { int pointCount = 0; for (DataPoint point : data) { - checkIsHistoryData(point.getMeasurementId(), time); + // checkIsHistoryData(point.getMeasurementId(), time); if (pointCount == 0) { pointCount++; @@ -103,7 +103,7 @@ public class NonAlignedChunkGroupWriterImpl implements IChunkGroupWriter { continue; } long time = tablet.timestamps[row]; - checkIsHistoryData(measurementId, time); + // checkIsHistoryData(measurementId, time); pointCount++; switch (tsDataType) { case INT32:
