This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch show-write-back-sink in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit cb354fb183c1802f2c5c034ae362d8f91bcbc858 Author: Steve Yurong Su <[email protected]> AuthorDate: Thu Mar 27 14:56:16 2025 +0800 Update IoTDBDatabaseIT.java --- .../org/apache/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 6235172841f..6cf26b01db8 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 class IoTDBDatabaseIT { "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(
