This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/tsfile.git
The following commit(s) were added to refs/heads/develop by this push:
new 666d6c2c Fix code scanning alerts (#169)
666d6c2c is described below
commit 666d6c2c23d60209c9ee4b4947d70896b4ca8f22
Author: Haonan <[email protected]>
AuthorDate: Mon Jul 8 15:23:27 2024 +0800
Fix code scanning alerts (#169)
---
.../java/org/apache/tsfile/encoding/decoder/DoubleRLBEDecoder.java | 5 +++--
.../java/org/apache/tsfile/encoding/decoder/LongRLBEDecoder.java | 5 +++--
2 files changed, 6 insertions(+), 4 deletions(-)
diff --git
a/java/tsfile/src/main/java/org/apache/tsfile/encoding/decoder/DoubleRLBEDecoder.java
b/java/tsfile/src/main/java/org/apache/tsfile/encoding/decoder/DoubleRLBEDecoder.java
index 883e0252..a31be5d0 100644
---
a/java/tsfile/src/main/java/org/apache/tsfile/encoding/decoder/DoubleRLBEDecoder.java
+++
b/java/tsfile/src/main/java/org/apache/tsfile/encoding/decoder/DoubleRLBEDecoder.java
@@ -84,7 +84,8 @@ public class DoubleRLBEDecoder extends Decoder {
// read the header of the block
readhead(buffer);
while (writeindex < blocksize - 1) {
- int seglength = 0, runlength = 0;
+ int seglength = 0;
+ long runlength = 0;
// read first 7 bits: length of each binary words.
for (int j = 6; j >= 0; j--) {
seglength |= (readbit(buffer) << j);
@@ -105,7 +106,7 @@ public class DoubleRLBEDecoder extends Decoder {
next = readbit(buffer);
}
// read the delta value one by one
- for (int i = 1; i <= runlength; i++) {
+ for (long i = 1; i <= runlength; i++) {
long readlongtemp = 0;
for (int k = seglength - 1; k >= 0; k--) {
diff --git
a/java/tsfile/src/main/java/org/apache/tsfile/encoding/decoder/LongRLBEDecoder.java
b/java/tsfile/src/main/java/org/apache/tsfile/encoding/decoder/LongRLBEDecoder.java
index a1020005..f41a5cd9 100644
---
a/java/tsfile/src/main/java/org/apache/tsfile/encoding/decoder/LongRLBEDecoder.java
+++
b/java/tsfile/src/main/java/org/apache/tsfile/encoding/decoder/LongRLBEDecoder.java
@@ -84,7 +84,8 @@ public class LongRLBEDecoder extends Decoder {
// read the header of the block
readhead(buffer);
while (writeindex < blocksize - 1) {
- int seglength = 0, runlength = 0;
+ int seglength = 0;
+ long runlength = 0;
// read first 7 bits: length of each binary words.
for (int j = 6; j >= 0; j--) {
seglength |= (readbit(buffer) << j);
@@ -105,7 +106,7 @@ public class LongRLBEDecoder extends Decoder {
next = readbit(buffer);
}
// read the delta value one by one
- for (int i = 1; i <= runlength; i++) {
+ for (long i = 1; i <= runlength; i++) {
long readlongtemp = 0;
for (int k = seglength - 1; k >= 0; k--) {
