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 e62bbf52833 Pipe: Enable showing WRITE_BACK_SINK (Fix IoTDBDatabaseIT)
(#15209)
e62bbf52833 is described below
commit e62bbf52833924c6155d9dd09b73f7ffe46ea820
Author: Steve Yurong Su <[email protected]>
AuthorDate: Thu Mar 27 16:19:19 2025 +0800
Pipe: Enable showing WRITE_BACK_SINK (Fix IoTDBDatabaseIT) (#15209)
---
.../org/apache/iotdb/relational/it/schema/IoTDBDatabaseIT.java | 10 +++-------
1 file changed, 3 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..491f277c5ef 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,12 @@ 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(
