This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch UserDefineTime-TsFile
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/UserDefineTime-TsFile by this
push:
new bb1d4c6559d fix
bb1d4c6559d is described below
commit bb1d4c6559d6bfa6fb8c51266aeba36488024abf
Author: Caideyipi <[email protected]>
AuthorDate: Mon Jan 26 19:11:46 2026 +0800
fix
---
.../metadata/fetcher/TableHeaderSchemaValidator.java | 13 +++++++++----
1 file changed, 9 insertions(+), 4 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/TableHeaderSchemaValidator.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/TableHeaderSchemaValidator.java
index 432670a8c33..1e9ff2f8a7f 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/TableHeaderSchemaValidator.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/TableHeaderSchemaValidator.java
@@ -177,24 +177,29 @@ public class TableHeaderSchemaValidator {
}
}
long realTimeIndex = 0;
+ boolean realWithoutTimeColumn = true;
+
for (final TsTableColumnSchema schema : table.getColumnList()) {
if (schema.getColumnCategory() == TsTableColumnCategory.TIME) {
+ realWithoutTimeColumn = false;
break;
}
if (schema.getColumnCategory() != TsTableColumnCategory.ATTRIBUTE) {
++realTimeIndex;
}
}
+
long inputTimeIndex = 0;
+ boolean inputWithoutTimeColumn = true;
for (final ColumnSchema schema : tableSchema.getColumns()) {
if (schema.getColumnCategory() == TsTableColumnCategory.TIME) {
+ inputWithoutTimeColumn = false;
break;
}
- if (schema.getColumnCategory() != TsTableColumnCategory.ATTRIBUTE) {
- ++inputTimeIndex;
- }
+ ++inputTimeIndex;
}
- if (inputTimeIndex != realTimeIndex) {
+ if (inputWithoutTimeColumn != realWithoutTimeColumn
+ || !inputWithoutTimeColumn && inputTimeIndex != realTimeIndex) {
needDecode4DifferentTimeColumn.set(true);
}
}