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 1be7c065327 fix bug
1be7c065327 is described below
commit 1be7c065327a0d0de6601a17d08d07651206b164
Author: HTHou <[email protected]>
AuthorDate: Tue Mar 25 11:40:17 2025 +0800
fix bug
---
iotdb-client/client-py/iotdb/tsfile/utils/tsblock_serde.py | 8 +++++---
1 file changed, 5 insertions(+), 3 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 416dfaa13cd..a09c73793e6 100644
--- a/iotdb-client/client-py/iotdb/tsfile/utils/tsblock_serde.py
+++ b/iotdb-client/client-py/iotdb/tsfile/utils/tsblock_serde.py
@@ -18,8 +18,6 @@
import numpy as np
-from iotdb.utils.IoTDBConstants import TSDataType
-
# Serialized tsBlock:
#
+-------------+---------------+---------+------------+-----------+----------+
@@ -229,7 +227,11 @@ def read_run_length_column(buffer, data_type,
position_count):
def repeat(column, data_type, position_count):
if data_type in (0, 5):
- return np.full(position_count, column)
+ return (
+ np.full(position_count, column[0])
+ if column.size == 1
+ else np.array(column * position_count, dtype=object)
+ )
else:
res = bytearray()
for _ in range(position_count):
