fixup! improve IT

apache · Jun 25, 2024 · f5daf86 · f5daf86
1 parent c96e933
commit f5daf86
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...src/test/java/org/apache/iotdb/subscription/it/dual/IoTDBSubscriptionConsumerGroupIT.java b/...src/test/java/org/apache/iotdb/subscription/it/dual/IoTDBSubscriptionConsumerGroupIT.java
@@ -879,7 +879,7 @@ private void createPipes(final long currentTime, final Map<String, String> conne
 
       extractorAttributes.put("inclusion", "data.insert");
       extractorAttributes.put("inclusion.exclusion", "data.delete");
-      extractorAttributes.put("pattern", "root.topic1.s");
+      extractorAttributes.put("path", "root.topic1.s");
       extractorAttributes.put("end-time", String.valueOf(currentTime - 1));
 
       final TSStatus status =
@@ -900,7 +900,7 @@ private void createPipes(final long currentTime, final Map<String, String> conne
 
       extractorAttributes.put("inclusion", "data.insert");
       extractorAttributes.put("inclusion.exclusion", "data.delete");
-      extractorAttributes.put("pattern", "root.topic2.s");
+      extractorAttributes.put("path", "root.topic2.s");
       extractorAttributes.put("start-time", String.valueOf(currentTime));
 
       final TSStatus status =