[iotdb] 01/01: [IOTDB-5965] Pipe: failed to transfer insert node when using schema template

[rong]

This is an automated email from the ASF dual-hosted git repository.

rong pushed a commit to branch IOTDB-5965
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 64f3654b1a678fbc6c78c0840cdd025d4b31bf0e
Author: Steve Yurong Su <r...@apache.org>
AuthorDate: Fri Jun 2 21:38:51 2023 +0800

    [IOTDB-5965] Pipe: failed to transfer insert node when using schema template
---
 .../connector/impl/iotdb/v1/request/PipeTransferInsertNodeReq.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/pipe/core/connector/impl/iotdb/v1/request/PipeTransferInsertNodeReq.java
 
b/server/src/main/java/org/apache/iotdb/db/pipe/core/connector/impl/iotdb/v1/request/PipeTransferInsertNodeReq.java
index 90af3b2fae6..5b4fc83ced8 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/pipe/core/connector/impl/iotdb/v1/request/PipeTransferInsertNodeReq.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/pipe/core/connector/impl/iotdb/v1/request/PipeTransferInsertNodeReq.java
@@ -50,8 +50,9 @@ public class PipeTransferInsertNodeReq extends 
TPipeTransferReq {
       statement.setMeasurements(node.getMeasurements());
       statement.setDataTypes(node.getDataTypes());
       statement.setValues(node.getValues());
-      statement.setNeedInferType(true);
+      statement.setNeedInferType(node.isNeedInferType());
       statement.setAligned(node.isAligned());
+      statement.setMeasurementSchemas(node.getMeasurementSchemas());
       return statement;
     }
 
@@ -67,6 +68,7 @@ public class PipeTransferInsertNodeReq extends 
TPipeTransferReq {
       statement.setRowCount(node.getRowCount());
       statement.setDataTypes(node.getDataTypes());
       statement.setAligned(node.isAligned());
+      statement.setMeasurementSchemas(node.getMeasurementSchemas());
       return statement;
     }