You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2023/03/09 06:33:38 UTC
[iotdb] 01/04: delete useless logs
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch SeriesScanOperatorImprove
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 1744d128773217e97f8c1cfe10db0c6a0ffcc9e9
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Thu Mar 9 10:13:47 2023 +0800
delete useless logs
---
.../mpp/execution/operator/process/join/RowBasedTimeJoinOperator.java | 3 +--
.../iotdb/tsfile/read/common/block/column/BinaryColumnBuilder.java | 3 +--
.../iotdb/tsfile/read/common/block/column/DoubleColumnBuilder.java | 3 +--
.../apache/iotdb/tsfile/read/common/block/column/IntColumnBuilder.java | 3 +--
4 files changed, 4 insertions(+), 8 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/join/RowBasedTimeJoinOperator.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/join/RowBasedTimeJoinOperator.java
index d920d8dc32..4ad910c1af 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/join/RowBasedTimeJoinOperator.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/join/RowBasedTimeJoinOperator.java
@@ -128,7 +128,7 @@ public class RowBasedTimeJoinOperator extends AbstractConsumeAllOperator {
if (retainedTsBlock != null) {
return getResultFromRetainedTsBlock();
}
- tsBlockBuilder.reset(20000);
+ tsBlockBuilder.reset();
if (!prepareInput()) {
return null;
}
@@ -282,7 +282,6 @@ public class RowBasedTimeJoinOperator extends AbstractConsumeAllOperator {
if (canCallNext[i]) {
if (children.get(i).hasNextWithTimer()) {
inputTsBlocks[i] = getNextTsBlock(i);
- LOGGER.info("get inputTsBlock with size: " + inputTsBlocks[i].getPositionCount());
canCallNext[i] = false;
if (isEmpty(i)) {
allReady = false;
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/BinaryColumnBuilder.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/BinaryColumnBuilder.java
index de01e7b336..ab35a31c41 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/BinaryColumnBuilder.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/BinaryColumnBuilder.java
@@ -148,13 +148,12 @@ public class BinaryColumnBuilder implements ColumnBuilder {
int newSize;
if (initialized) {
newSize = ColumnUtil.calculateNewArraySize(values.length);
+ LOGGER.info("grow capacity from {} to {}", values.length, newSize);
} else {
newSize = initialEntryCount;
initialized = true;
}
- LOGGER.info("grow capacity from {} to {}", values.length, newSize);
-
valueIsNull = Arrays.copyOf(valueIsNull, newSize);
values = Arrays.copyOf(values, newSize);
updateArraysDataSize();
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/DoubleColumnBuilder.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/DoubleColumnBuilder.java
index 2c54464c9e..e88982981e 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/DoubleColumnBuilder.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/DoubleColumnBuilder.java
@@ -146,13 +146,12 @@ public class DoubleColumnBuilder implements ColumnBuilder {
int newSize;
if (initialized) {
newSize = ColumnUtil.calculateNewArraySize(values.length);
+ LOGGER.info("grow capacity from {} to {}", values.length, newSize);
} else {
newSize = initialEntryCount;
initialized = true;
}
- LOGGER.info("grow capacity from {} to {}", values.length, newSize);
-
valueIsNull = Arrays.copyOf(valueIsNull, newSize);
values = Arrays.copyOf(values, newSize);
updateDataSize();
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/IntColumnBuilder.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/IntColumnBuilder.java
index 2d17b2c4a9..dcbd56bd16 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/IntColumnBuilder.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/IntColumnBuilder.java
@@ -146,13 +146,12 @@ public class IntColumnBuilder implements ColumnBuilder {
int newSize;
if (initialized) {
newSize = ColumnUtil.calculateNewArraySize(values.length);
+ LOGGER.info("grow capacity from {} to {}", values.length, newSize);
} else {
newSize = initialEntryCount;
initialized = true;
}
- LOGGER.info("grow capacity from {} to {}", values.length, newSize);
-
valueIsNull = Arrays.copyOf(valueIsNull, newSize);
values = Arrays.copyOf(values, newSize);
updateDataSize();