From d5c854d6eb2fb4de106f9f106d9e5e8715f2206b Mon Sep 17 00:00:00 2001 From: Itami Sho <42286868+MiniSho@users.noreply.github.com> Date: Wed, 25 Sep 2024 15:12:10 +0800 Subject: [PATCH] Pipe: Fix null output-series device issue in Two-Stage Processor (#13604) --- .../pipe/processor/twostage/plugin/TwoStageCountProcessor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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);