Update iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/ForecastTableFunction.java Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/ForecastTableFunction.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/ForecastTableFunction.java index af09dbf..442359a 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/ForecastTableFunction.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/ForecastTableFunction.java
@@ -158,7 +158,7 @@ int size = ReadWriteIOUtils.readInt(buffer); this.inputColumnTypes = new ArrayList<>(size); for (int i = 0; i < size; i++) { - inputColumnTypes.add(Type.valueOf(ReadWriteIOUtils.readString(buffer))); + inputColumnTypes.add(Type.valueOf(ReadWriteIOUtils.readByte(buffer))); } size = ReadWriteIOUtils.readInt(buffer); this.predicatedColumnTypes = new ArrayList<>(size);