diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/plugin/TwoStageCountProcessor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/plugin/TwoStageCountProcessor.java index da61c57e58c2..39eb3b62a788 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/plugin/TwoStageCountProcessor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/plugin/TwoStageCountProcessor.java @@ -240,7 +240,7 @@ private void collectGlobalCountIfNecessary(EventCollector eventCollector) throws final Tablet tablet = new Tablet( - outputSeries.getDeviceString(), + outputSeries.getIDeviceID().toString(), Collections.singletonList( new MeasurementSchema(outputSeries.getMeasurement(), TSDataType.INT64)), 1);