From 88aa7e29b1fb0b49f1ae9f91d318fc329d8f7133 Mon Sep 17 00:00:00 2001 From: Zhenyu Luo Date: Thu, 26 Sep 2024 19:57:50 +0800 Subject: [PATCH] PipePlugin: Add pipe consensus related plugins to blackList (#13642) --- .../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 07dc309383a4..67f3a0265afb 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 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,6 +154,7 @@ 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(), @@ -160,5 +162,6 @@ public String getClassName() { 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()))); }