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 2025/03/27 08:19:25 UTC
(iotdb) branch master updated: Pipe: Enable showing WRITE_BACK_SINK (Fix IoTDBDatabaseIT) (#15209)
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 <ro...@apache.org>
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(