Skip to content

Commit ffc7e75

Browse files
committed
fix
1 parent b04f819 commit ffc7e75

File tree

1 file changed

+13
-1
lines changed

1 file changed

+13
-1
lines changed

integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -133,6 +133,14 @@ public void testOPCUAServerSink() throws Exception {
133133
break;
134134
}
135135

136+
// Create the region first to avoid tsFile parsing
137+
TestUtils.executeNonQueries(
138+
env,
139+
Arrays.asList(
140+
"create aligned timeSeries root.db.opc(value double, quality boolean, other int32)",
141+
"insert into root.db.opc(time, value, quality, other) values (0, 0, true, 1)"),
142+
null);
143+
136144
while (true) {
137145
final int[] ports = EnvUtils.searchAvailablePorts();
138146
tcpPort = ports[0];
@@ -241,7 +249,11 @@ public void testOPCUAServerSink() throws Exception {
241249
sinkAttributes.put("password", "conflict");
242250
try {
243251
TestUtils.executeNonQuery(
244-
env, "create pipe test1 ('sink'='opc-ua-sink', 'password'='conflict')", null);
252+
env,
253+
String.format(
254+
"create pipe test1 ('sink'='opc-ua-sink', 'password'='conflict@pswd', 'tcp.port'='%s', 'http.port'='%s')",
255+
tcpPort, httpsPort),
256+
null);
245257
Assert.fail();
246258
} catch (final Exception e) {
247259
Assert.assertEquals(

0 commit comments

Comments
 (0)