From 9a4c002487427ee789626a85e0d711b912d3b534 Mon Sep 17 00:00:00 2001 From: Nero Date: Thu, 15 Jan 2026 10:42:47 +0800 Subject: [PATCH 1/2] Add an instance of validation. --- .../apache/tsfile/read/common/block/column/TsBlockSerde.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/TsBlockSerde.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/TsBlockSerde.java index 818ac3c2c..b0db1959a 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/TsBlockSerde.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/TsBlockSerde.java @@ -103,7 +103,8 @@ public ByteBuffer serialize(TsBlock tsBlock) throws IOException { // Value column data types. for (int i = 0; i < tsBlock.getValueColumnCount(); i++) { - if (tsBlock.getColumn(i).getDataType() == TSDataType.DATE) { + if ((tsBlock.getColumn(i) instanceof IntColumn) + && tsBlock.getColumn(i).getDataType() == TSDataType.DATE) { ((IntColumn) tsBlock.getColumn(i)).modifyDataType(TSDataType.INT32); } tsBlock.getColumn(i).getDataType().serializeTo(dataOutputStream); From 7535645c15f3f7c74eac74a78eed8f71532e1125 Mon Sep 17 00:00:00 2001 From: Nero Date: Thu, 15 Jan 2026 11:05:32 +0800 Subject: [PATCH 2/2] Add a comment. --- .../apache/tsfile/read/common/block/column/TsBlockSerde.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/TsBlockSerde.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/TsBlockSerde.java index b0db1959a..c8d4b0354 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/TsBlockSerde.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/block/column/TsBlockSerde.java @@ -103,6 +103,8 @@ public ByteBuffer serialize(TsBlock tsBlock) throws IOException { // Value column data types. for (int i = 0; i < tsBlock.getValueColumnCount(); i++) { + // To be compatible with the Python client, because it does not support data type values other + // than 0-5, the value of DATE is 9. if ((tsBlock.getColumn(i) instanceof IntColumn) && tsBlock.getColumn(i).getDataType() == TSDataType.DATE) { ((IntColumn) tsBlock.getColumn(i)).modifyDataType(TSDataType.INT32);