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 06:56:31 UTC
(iotdb) 01/01: Update IoTDBDatabaseIT.java
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 <ro...@apache.org>
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(