Skip to content

Commit 012e666

Browse files
committed
eliminate-fault
1 parent ae331f4 commit 012e666

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,8 @@ public void testOPCUAServerSink() throws Exception {
6666
try (final SyncConfigNodeIServiceClient client =
6767
(SyncConfigNodeIServiceClient) env.getLeaderConfigNodeConnection()) {
6868

69+
TestUtils.executeNonQuery(env, "insert into root.db.d1(time, s1) values (1, 1)", null);
70+
6971
final Map<String, String> sinkAttributes = new HashMap<>();
7072

7173
sinkAttributes.put("sink", "opc-ua-sink");
@@ -81,8 +83,6 @@ public void testOPCUAServerSink() throws Exception {
8183
.setProcessorAttributes(Collections.emptyMap()))
8284
.getCode());
8385

84-
TestUtils.executeNonQuery(env, "insert into root.db.d1(time, s1) values (1, 1)", null);
85-
8686
final OpcUaClient opcUaClient =
8787
getOpcUaClient("opc.tcp://127.0.0.1:12686/iotdb", SecurityPolicy.None, "root", "root");
8888
DataValue value =

0 commit comments

Comments
 (0)