From 4f31ae18b7d88b395c428e5cef28f1f3531f206f Mon Sep 17 00:00:00 2001 From: Steve Yurong Su Date: Thu, 27 Mar 2025 12:24:23 +0800 Subject: [PATCH 1/3] Pipe: Enable showing WRITE_BACK_SINK --- .../commons/pipe/agent/plugin/builtin/BuiltinPipePlugin.java | 1 - 1 file changed, 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 d191d4e386d75..0f2e39f245058 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 @@ -169,7 +169,6 @@ public String getClassName() { WEBSOCKET_SINK.getPipePluginName().toUpperCase(), OPC_UA_SINK.getPipePluginName().toUpperCase(), OPC_DA_SINK.getPipePluginName().toUpperCase(), - WRITE_BACK_SINK.getPipePluginName().toUpperCase(), SUBSCRIPTION_SINK.getPipePluginName().toUpperCase(), PIPE_CONSENSUS_ASYNC_SINK.getPipePluginName().toUpperCase()))); } From cb354fb183c1802f2c5c034ae362d8f91bcbc858 Mon Sep 17 00:00:00 2001 From: Steve Yurong Su Date: Thu, 27 Mar 2025 14:56:16 +0800 Subject: [PATCH 2/3] Update IoTDBDatabaseIT.java --- .../iotdb/relational/it/schema/IoTDBDatabaseIT.java | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBDatabaseIT.java b/integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBDatabaseIT.java index 6235172841fb8..6cf26b01db8ea 100644 --- a/integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBDatabaseIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBDatabaseIT.java @@ -530,16 +530,11 @@ public void testInformationSchema() throws SQLException { "id,", Collections.singleton("a2b,")); TestUtils.assertResultSetEqual( - statement.executeQuery("select * from pipe_plugins"), + statement.executeQuery("select * from pipe_plugins where plugin_name = 'IOTDB-THRIFT-SINK'"), "plugin_name,plugin_type,class_name,plugin_jar,", new HashSet<>( Arrays.asList( - "IOTDB-THRIFT-SSL-SINK,Builtin,org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.iotdb.thrift.IoTDBThriftSslConnector,null,", - "IOTDB-AIR-GAP-SINK,Builtin,org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.iotdb.airgap.IoTDBAirGapConnector,null,", - "DO-NOTHING-SINK,Builtin,org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.donothing.DoNothingConnector,null,", - "DO-NOTHING-PROCESSOR,Builtin,org.apache.iotdb.commons.pipe.agent.plugin.builtin.processor.donothing.DoNothingProcessor,null,", - "IOTDB-THRIFT-SINK,Builtin,org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.iotdb.thrift.IoTDBThriftConnector,null,", - "IOTDB-SOURCE,Builtin,org.apache.iotdb.commons.pipe.agent.plugin.builtin.extractor.iotdb.IoTDBExtractor,null,"))); + "IOTDB-THRIFT-SINK,Builtin,org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.iotdb.thrift.IoTDBThriftConnector,null,"))); statement.execute("create topic tp with ('start-time'='2025-01-13T10:03:19.229+08:00')"); TestUtils.assertResultSetEqual( From 4aa0e519f07839fcf7a0d7e9dc964a0186feaeb7 Mon Sep 17 00:00:00 2001 From: Steve Yurong Su Date: Thu, 27 Mar 2025 15:12:47 +0800 Subject: [PATCH 3/3] Update IoTDBDatabaseIT.java --- .../org/apache/iotdb/relational/it/schema/IoTDBDatabaseIT.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBDatabaseIT.java b/integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBDatabaseIT.java index 6cf26b01db8ea..491f277c5ef69 100644 --- a/integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBDatabaseIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBDatabaseIT.java @@ -530,7 +530,8 @@ public void testInformationSchema() throws SQLException { "id,", Collections.singleton("a2b,")); TestUtils.assertResultSetEqual( - statement.executeQuery("select * from pipe_plugins where plugin_name = 'IOTDB-THRIFT-SINK'"), + statement.executeQuery( + "select * from pipe_plugins where plugin_name = 'IOTDB-THRIFT-SINK'"), "plugin_name,plugin_type,class_name,plugin_jar,", new HashSet<>( Arrays.asList(