From eb5f42f46d0cb5503d581f7cdafa14a147adc36c Mon Sep 17 00:00:00 2001 From: Yabin Meng Date: Wed, 6 Oct 2021 10:55:32 -0500 Subject: [PATCH] Fix NullPointerException of checking namespace and topic deduplication status. --- .../java/io/nosqlbench/driver/pulsar/ops/ReadyPulsarOp.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/ReadyPulsarOp.java b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/ReadyPulsarOp.java index de26f15cc..8688627e0 100644 --- a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/ReadyPulsarOp.java +++ b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/ReadyPulsarOp.java @@ -461,7 +461,7 @@ public class ReadyPulsarOp implements OpDispenser { try { nsMsgDedup = pulsarAdmin.namespaces().getDeduplicationStatus(namespace); } - catch (PulsarAdminException pae) { + catch (Exception e) { // it is fine if we're unable to check namespace level setting; use default } @@ -471,7 +471,7 @@ public class ReadyPulsarOp implements OpDispenser { try { topicMsgDedup = pulsarAdmin.topics().getDeduplicationStatus(topic); } - catch (PulsarAdminException pae) { + catch (Exception e) { // it is fine if we're unable to check topic level setting; use default }