This is an automated email from the ASF dual-hosted git repository. lancelly pushed a commit to branch fixRealNumberCheck in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 7ddd244188c326ea087623bc303159d49065100c Author: lancelly <[email protected]> AuthorDate: Wed Dec 20 18:57:03 2023 +0800 fixRealNumberJudge --- iotdb-client/service-rpc/pom.xml | 4 ---- .../src/main/java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 12 ------------ 2 files changed, 16 deletions(-) diff --git a/iotdb-client/service-rpc/pom.xml b/iotdb-client/service-rpc/pom.xml index 6fbe96371ab..15836d4373a 100644 --- a/iotdb-client/service-rpc/pom.xml +++ b/iotdb-client/service-rpc/pom.xml @@ -70,10 +70,6 @@ <groupId>org.xerial.snappy</groupId> <artifactId>snappy-java</artifactId> </dependency> - <dependency> - <groupId>org.slf4j</groupId> - <artifactId>slf4j-api</artifactId> - </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> diff --git a/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java b/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java index 6505bcdedc1..6ff111e6bad 100644 --- a/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java +++ b/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java @@ -31,8 +31,6 @@ import org.apache.iotdb.tsfile.read.common.block.column.TsBlockSerde; import org.apache.iotdb.tsfile.utils.Binary; import org.apache.thrift.TException; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; import java.nio.ByteBuffer; import java.sql.Timestamp; @@ -79,12 +77,6 @@ public class IoTDBRpcDataSet { public int tsBlockSize; // the size of current tsBlock public int tsBlockIndex; // the row index in current tsBlock - private long bytebufferCapacity = 0L; - - private long bytebufferLimit = 0L; - - private static Logger Logger = LoggerFactory.getLogger(IoTDBRpcDataSet.class); - @SuppressWarnings({"squid:S3776", "squid:S107"}) // Suppress high Cognitive Complexity warning public IoTDBRpcDataSet( String sql, @@ -305,8 +297,6 @@ public class IoTDBRpcDataSet { return true; } else { try { - Logger.error("Total capacity is : {}MB.", bytebufferCapacity / 1024 / 1024); - Logger.error("Total limit is : {}MB.", bytebufferLimit / 1024 / 1024); close(); return false; } catch (TException e) { @@ -359,8 +349,6 @@ public class IoTDBRpcDataSet { public void constructOneTsBlock() { lastReadWasNull = false; ByteBuffer byteBuffer = queryResult.get(queryResultIndex); - bytebufferCapacity = bytebufferCapacity + (byteBuffer.capacity()); - bytebufferLimit = bytebufferLimit + (byteBuffer.limit()); queryResultIndex++; curTsBlock = serde.deserialize(byteBuffer); tsBlockIndex = -1;
