[iotdb] branch master updated: [IOTDB-5965] Pipe: failed to transfer insert node when using schema template (#10041)

[rong]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 322c9c68dbe [IOTDB-5965] Pipe: failed to transfer insert node when 
using schema template (#10041)
322c9c68dbe is described below

commit 322c9c68dbe3f2a4bab67afd0a84a46027544174
Author: Steve Yurong Su <r...@apache.org>
AuthorDate: Fri Jun 2 23:15:28 2023 +0800

    [IOTDB-5965] Pipe: failed to transfer insert node when using schema 
template (#10041)
---
 .../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;
     }