This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch query_v3_py
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/query_v3_py by this push:
new 5abf16746f9 fix bug
5abf16746f9 is described below
commit 5abf16746f9ddeaa6c63a01a84751e2bdd271873
Author: HTHou <[email protected]>
AuthorDate: Tue Mar 25 11:07:01 2025 +0800
fix bug
---
iotdb-client/client-py/iotdb/tsfile/utils/tsblock_serde.py | 8 ++++----
iotdb-client/client-py/iotdb/utils/iotdb_rpc_dataset.py | 1 -
2 files changed, 4 insertions(+), 5 deletions(-)
diff --git a/iotdb-client/client-py/iotdb/tsfile/utils/tsblock_serde.py
b/iotdb-client/client-py/iotdb/tsfile/utils/tsblock_serde.py
index 34cf02d205e..416dfaa13cd 100644
--- a/iotdb-client/client-py/iotdb/tsfile/utils/tsblock_serde.py
+++ b/iotdb-client/client-py/iotdb/tsfile/utils/tsblock_serde.py
@@ -227,13 +227,13 @@ def read_run_length_column(buffer, data_type,
position_count):
)
-def repeat(buffer, data_type, position_count):
- if data_type == 0 or data_type == 5:
- return buffer * position_count
+def repeat(column, data_type, position_count):
+ if data_type in (0, 5):
+ return np.full(position_count, column)
else:
res = bytearray()
for _ in range(position_count):
- res.extend(buffer if isinstance(buffer, bytes) else bytes(buffer))
+ res.extend(column if isinstance(column, bytes) else bytes(column))
return bytes(res)
diff --git a/iotdb-client/client-py/iotdb/utils/iotdb_rpc_dataset.py
b/iotdb-client/client-py/iotdb/utils/iotdb_rpc_dataset.py
index b67865e8be2..3ace4c1903d 100644
--- a/iotdb-client/client-py/iotdb/utils/iotdb_rpc_dataset.py
+++ b/iotdb-client/client-py/iotdb/utils/iotdb_rpc_dataset.py
@@ -180,7 +180,6 @@ class IoTDBRpcDataSet(object):
column_array = column_arrays[location]
null_indicator = null_indicators[location]
-
if len(column_array) < array_length or (
data_type == 0 and null_indicator is not None
):
