Skip to content

Commit 6025be5

Browse files
committed
fix
1 parent 8c682f1 commit 6025be5

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

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

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,7 @@
5353

5454
import java.io.File;
5555
import java.net.ConnectException;
56+
import java.util.Arrays;
5657
import java.util.Collections;
5758
import java.util.HashMap;
5859
import java.util.Map;
@@ -165,9 +166,12 @@ public void testOPCUAServerSink() throws Exception {
165166
break;
166167
}
167168

168-
TestUtils.executeNonQuery(
169+
// Create aligned timeSeries to avoid tsFile parsing
170+
TestUtils.executeNonQueries(
169171
env,
170-
"insert into root.db.opc(time, value, quality, other) values (1, 1, false, 1)",
172+
Arrays.asList(
173+
"create aligned timeSeries root.db.opc(value int32, quality boolean, other int32)",
174+
"insert into root.db.opc(time, value, quality, other) values (1, 1, false, 1)"),
171175
null);
172176

173177
long startTime = System.currentTimeMillis();

0 commit comments

Comments
 (0)