This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 906dc90 fix bug in IOTDB-207 (#385)
906dc90 is described below
commit 906dc900242bc7568bea72207b58c320adb71a3e
Author: SilverNarcissus <[email protected]>
AuthorDate: Tue Sep 10 20:16:38 2019 +0800
fix bug in IOTDB-207 (#385)
---
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 28 +++++++++++-----------
1 file changed, 14 insertions(+), 14 deletions(-)
diff --git
a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/ChunkWriterImpl.java
b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/ChunkWriterImpl.java
index 6b571bd..9dbc731 100644
---
a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/ChunkWriterImpl.java
+++
b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/ChunkWriterImpl.java
@@ -199,8 +199,8 @@ public class ChunkWriterImpl implements IChunkWriter {
@Override
public void write(long[] timestamps, int[] values, int batchSize) {
- this.time = timestamps[timestamps.length - 1];
- valueCountInOnePage += timestamps.length;
+ this.time = timestamps[batchSize - 1];
+ valueCountInOnePage += batchSize;
if (minTimestamp == Long.MIN_VALUE) {
minTimestamp = timestamps[0];
}
@@ -211,8 +211,8 @@ public class ChunkWriterImpl implements IChunkWriter {
@Override
public void write(long[] timestamps, long[] values, int batchSize) {
- this.time = timestamps[timestamps.length - 1];
- valueCountInOnePage += timestamps.length;
+ this.time = timestamps[batchSize - 1];
+ valueCountInOnePage += batchSize;
if (minTimestamp == Long.MIN_VALUE) {
minTimestamp = timestamps[0];
}
@@ -223,8 +223,8 @@ public class ChunkWriterImpl implements IChunkWriter {
@Override
public void write(long[] timestamps, boolean[] values, int batchSize) {
- this.time = timestamps[timestamps.length - 1];
- valueCountInOnePage += timestamps.length;
+ this.time = timestamps[batchSize - 1];
+ valueCountInOnePage += batchSize;
if (minTimestamp == Long.MIN_VALUE) {
minTimestamp = timestamps[0];
}
@@ -235,8 +235,8 @@ public class ChunkWriterImpl implements IChunkWriter {
@Override
public void write(long[] timestamps, float[] values, int batchSize) {
- this.time = timestamps[timestamps.length - 1];
- valueCountInOnePage += timestamps.length;
+ this.time = timestamps[batchSize - 1];
+ valueCountInOnePage += batchSize;
if (minTimestamp == Long.MIN_VALUE) {
minTimestamp = timestamps[0];
}
@@ -247,8 +247,8 @@ public class ChunkWriterImpl implements IChunkWriter {
@Override
public void write(long[] timestamps, double[] values, int batchSize) {
- this.time = timestamps[timestamps.length - 1];
- valueCountInOnePage += timestamps.length;
+ this.time = timestamps[batchSize - 1];
+ valueCountInOnePage += batchSize;
if (minTimestamp == Long.MIN_VALUE) {
minTimestamp = timestamps[0];
}
@@ -259,8 +259,8 @@ public class ChunkWriterImpl implements IChunkWriter {
@Override
public void write(long[] timestamps, BigDecimal[] values, int batchSize) {
- this.time = timestamps[timestamps.length - 1];
- valueCountInOnePage += timestamps.length;
+ this.time = timestamps[batchSize - 1];
+ valueCountInOnePage += batchSize;
if (minTimestamp == Long.MIN_VALUE) {
minTimestamp = timestamps[0];
}
@@ -271,8 +271,8 @@ public class ChunkWriterImpl implements IChunkWriter {
@Override
public void write(long[] timestamps, Binary[] values, int batchSize) {
- this.time = timestamps[timestamps.length - 1];
- valueCountInOnePage += timestamps.length;
+ this.time = timestamps[batchSize - 1];
+ valueCountInOnePage += batchSize;
if (minTimestamp == Long.MIN_VALUE) {
minTimestamp = timestamps[0];
}
