[IOTDB-5965] Pipe: failed to transfer insert node when using schema template (#10041)
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 90af3b2..5b4fc83 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 @@ 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 @@ statement.setRowCount(node.getRowCount()); statement.setDataTypes(node.getDataTypes()); statement.setAligned(node.isAligned()); + statement.setMeasurementSchemas(node.getMeasurementSchemas()); return statement; }