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

fail if field is not found

Browse Source
This commit is contained in:
Enrico Olivelli
2022-01-26 17:00:41 +01:00
parent 614fb3bb51
commit 2e8fbd7102
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

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