This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch fix-partial-pipe-13
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/fix-partial-pipe-13 by this
push:
new 628c40dfbcf try
628c40dfbcf is described below
commit 628c40dfbcf6f599740dd3594ef707c26ad370c1
Author: Caideyipi <[email protected]>
AuthorDate: Mon Mar 23 19:24:59 2026 +0800
try
---
.../pipe/it/autocreate/IoTDBPipeDataSinkIT.java | 29 ++++++++++++++++++++--
1 file changed, 27 insertions(+), 2 deletions(-)
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeDataSinkIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeDataSinkIT.java
index 5216fe20a27..9b9da301c42 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeDataSinkIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeDataSinkIT.java
@@ -46,7 +46,7 @@ import java.util.function.Consumer;
@Category({MultiClusterIT2AutoCreateSchema.class})
public class IoTDBPipeDataSinkIT extends AbstractPipeDualAutoIT {
@Test
- public void testThriftConnectorWithRealtimeFirstDisabled() throws Exception {
+ public void testThriftSinkWithRealtimeFirstDisabled() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
final String receiverIp = receiverDataNode.getIp();
@@ -196,7 +196,7 @@ public class IoTDBPipeDataSinkIT extends
AbstractPipeDualAutoIT {
}
@Test
- public void testLegacyConnector() throws Exception {
+ public void testLegacySink() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
final String receiverIp = receiverDataNode.getIp();
@@ -503,4 +503,29 @@ public class IoTDBPipeDataSinkIT extends
AbstractPipeDualAutoIT {
Collections.unmodifiableSet(new HashSet<>(Arrays.asList("1,1.0,",
"2,1.0,"))));
}
}
+
+ @Test
+ public void testSpecialPartialInsert() throws Exception {
+ try (final Connection connection = senderEnv.getConnection();
+ final Statement statement = connection.createStatement()) {
+ statement.execute(
+ String.format(
+ "create pipe a2b with sink ('node-urls'='%s')",
+
receiverEnv.getDataNodeWrapperList().get(0).getIpAndPortString()));
+ }
+
+ TestUtils.executeNonQueries(
+ senderEnv,
+ Arrays.asList(
+ "create timeSeries root.vehicle.d0.s1 double",
+ "create timeSeries root.vehicle.d0.s2 float",
+ "insert into root.vehicle.d0(time, s1, s2) values (2, 1, abc)"),
+ null);
+
+ TestUtils.assertDataEventuallyOnEnv(
+ receiverEnv,
+ "select * from root.vehicle.**",
+ "Time,root.vehicle.d0.s1,root.vehicle.d0.s2",
+ Collections.singleton("2,1.0,null"));
+ }
}