This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch mergemaster0808 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 0475da8781e4535b2d9f4674904be9c0d37c22a3 Author: Caideyipi <[email protected]> AuthorDate: Fri Aug 2 18:07:49 2024 +0800 Pipe: Fix the class not found exception of OPC UA connector (#13086) (cherry picked from commit d8a200516c1f61deec78d1a50c1172a191a645dc) --- .../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 53 ++++++++++++++++++++++ pom.xml | 2 +- 2 files changed, 54 insertions(+), 1 deletion(-) 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 new file mode 100644 index 00000000000..fb4912ee48e --- /dev/null +++ b/integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java @@ -0,0 +1,53 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ + +package org.apache.iotdb.pipe.it.single; + +import org.apache.iotdb.common.rpc.thrift.TSStatus; +import org.apache.iotdb.commons.client.sync.SyncConfigNodeIServiceClient; +import org.apache.iotdb.confignode.rpc.thrift.TCreatePipeReq; +import org.apache.iotdb.rpc.TSStatusCode; + +import org.junit.Assert; +import org.junit.Test; + +import java.util.HashMap; +import java.util.Map; + +public class IoTDBPipeOPCUAIT extends AbstractPipeSingleIT { + @Test + public void testOPCUASink() throws Exception { + try (final SyncConfigNodeIServiceClient client = + (SyncConfigNodeIServiceClient) env.getLeaderConfigNodeConnection()) { + + final Map<String, String> extractorAttributes = new HashMap<>(); + final Map<String, String> processorAttributes = new HashMap<>(); + final Map<String, String> connectorAttributes = new HashMap<>(); + + connectorAttributes.put("sink", "opc-ua-sink"); + + final TSStatus status = + client.createPipe( + new TCreatePipeReq("testPipe", connectorAttributes) + .setExtractorAttributes(extractorAttributes) + .setProcessorAttributes(processorAttributes)); + Assert.assertEquals(TSStatusCode.SUCCESS_STATUS.getStatusCode(), status.getCode()); + } + } +} diff --git a/pom.xml b/pom.xml index dcd5147020f..75b53374549 100644 --- a/pom.xml +++ b/pom.xml @@ -114,7 +114,7 @@ <maven.compiler.source>1.8</maven.compiler.source> <maven.compiler.target>1.8</maven.compiler.target> <micrometer.version>1.11.4</micrometer.version> - <milo.version>0.6.11</milo.version> + <milo.version>0.6.10</milo.version> <!-- It seems that powermock is having issues with the newest mockito versions --> <mockito.version>2.23.4</mockito.version> <!-- This was the last version to support Java 8 -->
