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

fix logger

Browse Source
This commit is contained in:
Enrico Olivelli 2022-01-26 17:02:34 +01:00
parent 2e8fbd7102
commit 1c91469e64
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/PulsarConsumerOp.java
View File

@ -239,7 +239,7 @@ public class PulsarConsumerOp implements PulsarOp {
field = keyPart.getField(payloadRttTrackingField);
} catch (AvroRuntimeException err) {
// field is not in the key
logger.error("Cannot find "+payloadRttTrackingField+" in key " + keyPart + ": " + err);
logger.error("Cannot find {} in key {}: {}", payloadRttTrackingField, keyPart, err + "");
}
}
// look into the Value
@ -249,11 +249,11 @@ public class PulsarConsumerOp implements PulsarOp {
field = valuePart.getField(payloadRttTrackingField);
} catch (AvroRuntimeException err) {
// field is not in the value
logger.error("Cannot find "+payloadRttTrackingField+" in value " + valuePart + ": " + err);
logger.error("Cannot find {} in value {}: {}", payloadRttTrackingField, valuePart, err + "");
}
}
if (field == null) {
throw new RuntimeException("Cannot find field " + payloadRttTrackingField + " in " + keyValue.getKey() + " and " + keyValue.getValue());
throw new RuntimeException("Cannot find field {}" + payloadRttTrackingField + " in " + keyValue.getKey() + " and " + keyValue.getValue());
}
} else {
field = pulsarGenericRecord.getField(payloadRttTrackingField);
@ -266,7 +266,7 @@ public class PulsarConsumerOp implements PulsarOp {
extractedSendTime = Long.valueOf(field.toString());
}
} else {
logger.error("Cannot find " + payloadRttTrackingField + " in value " + pulsarGenericRecord);
logger.error("Cannot find {} in value {}", payloadRttTrackingField, pulsarGenericRecord);
}
done = true;
}