Skip to content

Commit 87b7f1d

Browse files
committed
fix
1 parent 9d7c7b6 commit 87b7f1d

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

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

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,6 @@
6565
@RunWith(IoTDBTestRunner.class)
6666
@Category({MultiClusterIT1.class})
6767
public class IoTDBPipeOPCUAIT extends AbstractPipeSingleIT {
68-
private static final Logger logger = LoggerFactory.getLogger(IoTDBPipeOPCUAIT.class);
6968

7069
@Test
7170
public void testOPCUAServerSink() throws Exception {
@@ -107,10 +106,6 @@ public void testOPCUAServerSink() throws Exception {
107106
if (e.getCause() instanceof ConnectException) {
108107
continue;
109108
} else {
110-
final String lockPath = EnvUtils.getLockFilePath(tcpPort);
111-
if (!new File(lockPath).delete()) {
112-
logger.error("Delete lock file {} failed", lockPath);
113-
}
114109
throw e;
115110
}
116111
}
@@ -238,7 +233,7 @@ public void testOPCUAServerSink() throws Exception {
238233
if (tcpPort >= 0) {
239234
final String lockPath = EnvUtils.getLockFilePath(tcpPort);
240235
if (!new File(lockPath).delete()) {
241-
logger.error("Delete lock file {} failed", lockPath);
236+
System.out.printf("Delete lock file %s failed%n", lockPath);
242237
}
243238
}
244239
}

0 commit comments

Comments
 (0)