diff --git a/driver-jms/src/main/java/io/nosqlbench/driver/jms/util/PulsarConfig.java b/driver-jms/src/main/java/io/nosqlbench/driver/jms/util/PulsarConfig.java index 1d5cc6d5b..ffb6dd09e 100644 --- a/driver-jms/src/main/java/io/nosqlbench/driver/jms/util/PulsarConfig.java +++ b/driver-jms/src/main/java/io/nosqlbench/driver/jms/util/PulsarConfig.java @@ -79,7 +79,7 @@ public class PulsarConfig { logger.error("Can't read the specified config properties file: " + fileName); ioe.printStackTrace(); } catch (ConfigurationException cex) { - logger.error("Error loading configuration items from the specified config properties file: " + fileName); + logger.error("Error loading configuration items from the specified config properties file: " + fileName + ":" + cex.getMessage()); cex.printStackTrace(); } } diff --git a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/PulsarAdminNamespaceOp.java b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/PulsarAdminNamespaceOp.java index e2ebdc662..5200126a4 100644 --- a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/PulsarAdminNamespaceOp.java +++ b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/PulsarAdminNamespaceOp.java @@ -44,7 +44,7 @@ public class PulsarAdminNamespaceOp extends PulsarAdminOp { future.whenComplete((unused, throwable) -> logger.trace("Successfully created namespace \"" + fullNsName + "\" asynchronously!")) .exceptionally(ex -> { - logger.error("Failed to create namespace \"" + fullNsName + "\" asynchronously!"); + logger.error("Failed to create namespace \"" + fullNsName + "\" asynchronously!:" + ex.getMessage()); return null; }); } diff --git a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/util/PulsarActivityUtil.java b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/util/PulsarActivityUtil.java index d47a856f6..a70bb481c 100644 --- a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/util/PulsarActivityUtil.java +++ b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/util/PulsarActivityUtil.java @@ -1,7 +1,6 @@ package io.nosqlbench.driver.pulsar.util; import com.fasterxml.jackson.databind.ObjectMapper; -import java.util.*; import org.apache.commons.lang3.StringUtils; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; @@ -13,6 +12,7 @@ import java.nio.charset.StandardCharsets; import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths; +import java.util.*; import java.util.stream.Collectors; import java.util.stream.Stream; @@ -462,7 +462,7 @@ public class PulsarActivityUtil { Path filePath = Paths.get(URI.create(schemaDefinitionStr)); schemaDefinitionStr = Files.readString(filePath, StandardCharsets.US_ASCII); } catch (IOException ioe) { - throw new RuntimeException("Error reading the specified \"Avro\" schema definition file: " + definitionStr); + throw new RuntimeException("Error reading the specified \"Avro\" schema definition file: " + definitionStr + ": " + ioe.getMessage()); } }