(iotdb) branch master updated: Pipe: Fixed the unstable OPC UA IT 2 (#16975)

[justinchen]

This is an automated email from the ASF dual-hosted git repository.

justinchen 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 c3d73e67b04 Pipe: Fixed the unstable OPC UA IT 2 (#16975)
c3d73e67b04 is described below

commit c3d73e67b041862e0043c948dcd1299aeccc0694
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Thu Jan 1 10:41:13 2026 +0800

    Pipe: Fixed the unstable OPC UA IT 2 (#16975)
---
 .../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java     | 30 +++++++++++++++-------
 1 file changed, 21 insertions(+), 9 deletions(-)

diff --git 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java
 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java
index d929f747ebb..67060c6002b 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java
@@ -85,6 +85,7 @@ public class IoTDBPipeOPCUAIT extends AbstractPipeSingleIT {
   @Test
   public void testOPCUAServerSink() throws Exception {
     int tcpPort = -1;
+    int httpsPort = -1;
     try (final SyncConfigNodeIServiceClient client =
         (SyncConfigNodeIServiceClient) env.getLeaderConfigNodeConnection()) {
 
@@ -101,7 +102,7 @@ public class IoTDBPipeOPCUAIT extends AbstractPipeSingleIT {
       while (true) {
         final int[] ports = EnvUtils.searchAvailablePorts();
         tcpPort = ports[0];
-        final int httpsPort = ports[1];
+        httpsPort = ports[1];
         sinkAttributes.put("tcp.port", Integer.toString(tcpPort));
         sinkAttributes.put("https.port", Integer.toString(httpsPort));
 
@@ -133,10 +134,18 @@ public class IoTDBPipeOPCUAIT extends 
AbstractPipeSingleIT {
         break;
       }
 
+      // Create the region first to avoid tsFile parsing
+      TestUtils.executeNonQueries(
+          env,
+          Arrays.asList(
+              "create aligned timeSeries root.db.opc(value double, quality 
boolean, other int32)",
+              "insert into root.db.opc(time, value, quality, other) values (0, 
0, true, 1)"),
+          null);
+
       while (true) {
         final int[] ports = EnvUtils.searchAvailablePorts();
         tcpPort = ports[0];
-        final int httpsPort = ports[1];
+        httpsPort = ports[1];
         sinkAttributes.put("tcp.port", Integer.toString(tcpPort));
         sinkAttributes.put("https.port", Integer.toString(httpsPort));
         sinkAttributes.put("with-quality", "true");
@@ -166,12 +175,9 @@ public class IoTDBPipeOPCUAIT extends AbstractPipeSingleIT 
{
         break;
       }
 
-      // Create aligned timeSeries to avoid tsFile parsing
-      TestUtils.executeNonQueries(
+      TestUtils.executeNonQuery(
           env,
-          Arrays.asList(
-              "create aligned timeSeries root.db.opc(value double, quality 
boolean, other int32)",
-              "insert into root.db.opc(time, value, quality, other) values (1, 
1, false, 1)"),
+          "insert into root.db.opc(time, value, quality, other) values (1, 1, 
false, 1)",
           null);
 
       long startTime = System.currentTimeMillis();
@@ -241,11 +247,17 @@ public class IoTDBPipeOPCUAIT extends 
AbstractPipeSingleIT {
       sinkAttributes.put("password", "conflict");
       try {
         TestUtils.executeNonQuery(
-            env, "create pipe test1 ('sink'='opc-ua-sink', 
'password'='conflict')", null);
+            env,
+            String.format(
+                "create pipe test1 ('sink'='opc-ua-sink', 
'password'='conflict@pswd', 'tcp.port'='%s', 'https.port'='%s')",
+                tcpPort, httpsPort),
+            null);
         Assert.fail();
       } catch (final Exception e) {
         Assert.assertEquals(
-            "org.apache.iotdb.jdbc.IoTDBSQLException: 1107: The existing 
server with tcp port 12686 and https port 8443's password **** conflicts to the 
new password ****, reject reusing.",
+            String.format(
+                "org.apache.iotdb.jdbc.IoTDBSQLException: 1107: The existing 
server with tcp port %s and https port %s's password **** conflicts to the new 
password ****, reject reusing.",
+                tcpPort, httpsPort),
             e.getMessage());
       }
     } finally {