We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3b89d41 commit f5baef5Copy full SHA for f5baef5
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSink.java
@@ -285,6 +285,9 @@ private void customizeServer(final PipeParameters parameters) {
285
: CONNECTOR_OPC_UA_SECURITY_POLICY_SERVER_DEFAULT_VALUES.stream())
286
.map(this::getSecurityPolicy)
287
.collect(Collectors.toSet());
288
+ if (securityPolicies.isEmpty()) {
289
+ throw new PipeException("The security policy cannot be empty.");
290
+ }
291
292
synchronized (SERVER_KEY_TO_REFERENCE_COUNT_AND_NAME_SPACE_MAP) {
293
serverKey = httpsBindPort + ":" + tcpBindPort;
0 commit comments