IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

init pulsar cache early to avoid NPE on initialization error

Browse Source
This commit is contained in:
Jonathan Shook 2021-11-09 22:29:54 -06:00
parent 6f29b9005d
commit e5715e17a8
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/PulsarActivity.java
View File

@ -77,6 +77,8 @@ public class PulsarActivity extends SimpleActivity implements ActivityDefObserve
@Override @Override
public void initActivity() { public void initActivity() {
super.initActivity(); super.initActivity();
pulsarCache = new PulsarSpaceCache(this);
bytesCounter = ActivityMetrics.counter(activityDef, "bytes"); bytesCounter = ActivityMetrics.counter(activityDef, "bytes");
messageSizeHistogram = ActivityMetrics.histogram(activityDef, "message_size"); messageSizeHistogram = ActivityMetrics.histogram(activityDef, "message_size");
bindTimer = ActivityMetrics.timer(activityDef, "bind"); bindTimer = ActivityMetrics.timer(activityDef, "bind");
@ -101,7 +103,6 @@ public class PulsarActivity extends SimpleActivity implements ActivityDefObserve
initPulsarAdminAndClientObj(); initPulsarAdminAndClientObj();
createPulsarSchemaFromConf(); createPulsarSchemaFromConf();
pulsarCache = new PulsarSpaceCache(this);
this.sequencer = createOpSequence((ot) -> new ReadyPulsarOp(ot, pulsarCache, this)); this.sequencer = createOpSequence((ot) -> new ReadyPulsarOp(ot, pulsarCache, this));
setDefaultsFromOpSequence(sequencer); setDefaultsFromOpSequence(sequencer);