PipePlugin: Add pipe consensus related plugins to blackList (apache#1…

…3642)
luoluoyuyu · Sep 26, 2024 · 88aa7e2 · 88aa7e2
1 parent f27a249
commit 88aa7e2
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...s/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/BuiltinPipePlugin.java b/...s/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/BuiltinPipePlugin.java
@@ -142,6 +142,7 @@ public String getClassName() {
                   COUNT_POINT_PROCESSOR.getPipePluginName().toUpperCase(),
                   STANDARD_STATISTICS_PROCESSOR.getPipePluginName().toUpperCase(),
                   TUMBLING_WINDOWING_PROCESSOR.getPipePluginName().toUpperCase(),
+                  PIPE_CONSENSUS_PROCESSOR.getPipePluginName().toUpperCase(),
                   // Connectors
                   DO_NOTHING_CONNECTOR.getPipePluginName().toUpperCase(),
                   IOTDB_THRIFT_CONNECTOR.getPipePluginName().toUpperCase(),
@@ -153,12 +154,14 @@ public String getClassName() {
                   WEBSOCKET_CONNECTOR.getPipePluginName().toUpperCase(),
                   OPC_UA_CONNECTOR.getPipePluginName().toUpperCase(),
                   WRITE_BACK_CONNECTOR.getPipePluginName().toUpperCase(),
+                  PIPE_CONSENSUS_ASYNC_CONNECTOR.getPipePluginName().toUpperCase(),
                   // Sinks
                   IOTDB_THRIFT_SYNC_SINK.getPipePluginName().toUpperCase(),
                   IOTDB_THRIFT_ASYNC_SINK.getPipePluginName().toUpperCase(),
                   IOTDB_LEGACY_PIPE_SINK.getPipePluginName().toUpperCase(),
                   WEBSOCKET_SINK.getPipePluginName().toUpperCase(),
                   OPC_UA_SINK.getPipePluginName().toUpperCase(),
                   WRITE_BACK_SINK.getPipePluginName().toUpperCase(),
-                  SUBSCRIPTION_SINK.getPipePluginName().toUpperCase())));
+                  SUBSCRIPTION_SINK.getPipePluginName().toUpperCase(),
+                  PIPE_CONSENSUS_ASYNC_SINK.getPipePluginName().toUpperCase())));
 }