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 2022/05/27 02:52:26 UTC
[iotdb] 01/02: ignore checks
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 <jt...@163.com>
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: