You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2024/09/26 11:57:56 UTC
(iotdb) branch master updated: PipePlugin: Add pipe consensus related plugins to blackList (#13642)
This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 879715174f2 PipePlugin: Add pipe consensus related plugins to blackList (#13642)
879715174f2 is described below
commit 879715174f2ed972df300a4d8eff1a26aeb61ff5
Author: Zhenyu Luo <lu...@gmail.com>
AuthorDate: Thu Sep 26 19:57:50 2024 +0800
PipePlugin: Add pipe consensus related plugins to blackList (#13642)
---
.../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())));
}