From 718f7fddeeee9627f00185bd279140fb4bcefb0b Mon Sep 17 00:00:00 2001 From: luoluoyuyu Date: Fri, 10 Jan 2025 18:02:50 +0800 Subject: [PATCH] fix --- .../statement/PipeConvertedInsertTabletStatement.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/transform/statement/PipeConvertedInsertTabletStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/transform/statement/PipeConvertedInsertTabletStatement.java index cc5b611c94ec..fe33e3702322 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/transform/statement/PipeConvertedInsertTabletStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/transform/statement/PipeConvertedInsertTabletStatement.java @@ -23,6 +23,7 @@ import org.apache.iotdb.db.queryengine.plan.statement.crud.InsertTabletStatement; import org.apache.tsfile.enums.TSDataType; +import org.apache.tsfile.write.schema.MeasurementSchema; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -43,11 +44,6 @@ public PipeConvertedInsertTabletStatement( // InsertBaseStatement devicePath = insertTabletStatement.getDevicePath(); isAligned = insertTabletStatement.isAligned(); - columnCategories = insertTabletStatement.getColumnCategories(); - idColumnIndices = insertTabletStatement.getIdColumnIndices(); - attrColumnIndices = insertTabletStatement.getAttrColumnIndices(); - writeToTable = insertTabletStatement.isWriteToTable(); - databaseName = insertTabletStatement.getDatabaseName().orElse(null); // InsertTabletStatement times = insertTabletStatement.getTimes(); bitMaps = insertTabletStatement.getBitMaps();