From 83118a479469d3eb62bd006a5ff5298f32533956 Mon Sep 17 00:00:00 2001 From: Sahan KJ Date: Thu, 4 Jan 2024 16:52:27 +0530 Subject: [PATCH 1/2] adding the warning --- .../io/nosqlbench/adapter/cqld4/Cqld4Space.java | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/Cqld4Space.java b/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/Cqld4Space.java index 96f2faa27..2585f4cb4 100644 --- a/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/Cqld4Space.java +++ b/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/Cqld4Space.java @@ -97,8 +97,18 @@ public class Cqld4Space implements AutoCloseable { // int port = cfg.getOptional(int.class, "port").orElse(9042); Optional scb = cfg.getOptional(String.class, "secureconnectbundle", "scb"); - scb.flatMap(s -> NBIO.all().pathname(s).first().map(Content::getInputStream)) - .map(builder::withCloudSecureConnectBundle); + + if (scb.isPresent()) { + Optional stream = + scb.flatMap(s -> NBIO.all().pathname(s).first().map(Content::getInputStream)); + if (stream.isPresent()) { + stream.map(builder::withCloudSecureConnectBundle); + } else { + String error = String.format("Unable to load Secure Connect Bundle from path %s", scb.get()); + logger.error(error); + throw new RuntimeException(error); + } + } Optional> contactPointsOption = cfg .getOptional("host", "hosts") From 2166331e831d58a03538d123677ea55a6d630812 Mon Sep 17 00:00:00 2001 From: Sahan KJ Date: Wed, 10 Jan 2024 10:59:43 +0530 Subject: [PATCH 2/2] added the required imports --- .../src/main/java/io/nosqlbench/adapter/cqld4/Cqld4Space.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/Cqld4Space.java b/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/Cqld4Space.java index 2585f4cb4..1ba0c73ff 100644 --- a/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/Cqld4Space.java +++ b/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/Cqld4Space.java @@ -37,6 +37,7 @@ import org.apache.logging.log4j.Logger; import javax.net.ssl.SSLContext; import java.io.IOException; +import java.io.InputStream; import java.net.InetSocketAddress; import java.nio.file.Files; import java.nio.file.Path; @@ -97,7 +98,7 @@ public class Cqld4Space implements AutoCloseable { // int port = cfg.getOptional(int.class, "port").orElse(9042); Optional scb = cfg.getOptional(String.class, "secureconnectbundle", "scb"); - + if (scb.isPresent()) { Optional stream = scb.flatMap(s -> NBIO.all().pathname(s).first().map(Content::getInputStream));