diff --git a/perf-ycsb/src/main/java/io/streamnative/oxia/client/perf/ycsb/Worker.java b/perf-ycsb/src/main/java/io/streamnative/oxia/client/perf/ycsb/Worker.java index c803b24c..1575b99a 100644 --- a/perf-ycsb/src/main/java/io/streamnative/oxia/client/perf/ycsb/Worker.java +++ b/perf-ycsb/src/main/java/io/streamnative/oxia/client/perf/ycsb/Worker.java @@ -135,24 +135,28 @@ public Worker(WorkerOptions options, OpenTelemetry openTelemetry) { this.operationWriteSuccessAttributes = Attributes.builder() .put("type", "write") + .put("value.size", options.valueSize) .put("worker", options.workerName) .put("response", "success") .build(); this.operationWriteFailedAttributes = Attributes.builder() .put("type", "write") + .put("value.size", options.valueSize) .put("worker", options.workerName) .put("response", "failed") .build(); this.operationReadSuccessAttributes = Attributes.builder() .put("type", "read") + .put("value.size", options.valueSize) .put("worker", options.workerName) .put("response", "success") .build(); this.operationReadFailedAttributes = Attributes.builder() .put("type", "read") + .put("value.size", options.valueSize) .put("worker", options.workerName) .put("response", "failed") .build();