(iotdb) branch rc/1.3.3 updated: PipePlugin: Add pipe consensus related plugins to blackList (#13642) (#13644)

[rong]

This is an automated email from the ASF dual-hosted git repository.

rong pushed a commit to branch rc/1.3.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rc/1.3.3 by this push:
     new 866eab02b8e PipePlugin: Add pipe consensus related plugins to 
blackList (#13642) (#13644)
866eab02b8e is described below

commit 866eab02b8ecd4c0b0fed171638872fb85b85bb5
Author: Zhenyu Luo <luoluoyuyu2...@gmail.com>
AuthorDate: Thu Sep 26 20:20:24 2024 +0800

    PipePlugin: Add pipe consensus related plugins to blackList (#13642) 
(#13644)
---
 .../iotdb/commons/pipe/agent/plugin/builtin/BuiltinPipePlugin.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/BuiltinPipePlugin.java
 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/BuiltinPipePlugin.java
index 07dc309383a..67f3a0265af 100644
--- 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/BuiltinPipePlugin.java
+++ 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/BuiltinPipePlugin.java
@@ -142,6 +142,7 @@ public enum BuiltinPipePlugin {
                   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,6 +154,7 @@ public enum BuiltinPipePlugin {
                   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(),
@@ -160,5 +162,6 @@ public enum BuiltinPipePlugin {
                   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())));
 }