This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/dev/1.3 by this push:
new d16b5ea0e5a Pipe: Fixed the pipe parsing bug for logical view (#15055)
(#15056)
d16b5ea0e5a is described below
commit d16b5ea0e5a0c6f8cc71aaf6501f71d28bb3e4e0
Author: Caideyipi <[email protected]>
AuthorDate: Tue Mar 11 12:08:14 2025 +0800
Pipe: Fixed the pipe parsing bug for logical view (#15055) (#15056)
---
.../pipe/extractor/PipeConfigPhysicalPlanPatternParseVisitor.java | 2 +-
.../pipe/extractor/PipeConfigPhysicalPlanPatternParseVisitorTest.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanPatternParseVisitor.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanPatternParseVisitor.java
index 6b9e99900bc..6c9430e3795 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanPatternParseVisitor.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanPatternParseVisitor.java
@@ -240,7 +240,7 @@ public class PipeConfigPhysicalPlanPatternParseVisitor
pattern.getIntersection(
PathPatternTree.deserialize(pipeDeleteLogicalViewPlan.getPatternTreeBytes()));
return !intersectedTree.isEmpty()
- ? Optional.of(new
PipeDeleteTimeSeriesPlan(intersectedTree.serialize()))
+ ? Optional.of(new
PipeDeleteLogicalViewPlan(intersectedTree.serialize()))
: Optional.empty();
} catch (final IOException e) {
LOGGER.warn(
diff --git
a/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanPatternParseVisitorTest.java
b/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanPatternParseVisitorTest.java
index 16bf1e344ff..062fa6299d6 100644
---
a/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanPatternParseVisitorTest.java
+++
b/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanPatternParseVisitorTest.java
@@ -331,7 +331,7 @@ public class PipeConfigPhysicalPlanPatternParseVisitorTest {
Assert.assertEquals(
Collections.singletonList(new PartialPath("root.db.device.s1")),
PathPatternTree.deserialize(
- ((PipeDeleteTimeSeriesPlan)
+ ((PipeDeleteLogicalViewPlan)
IoTDBConfigRegionExtractor.PATTERN_PARSE_VISITOR
.visitPipeDeleteLogicalView(
new
PipeDeleteLogicalViewPlan(patternTree.serialize()),
