I use in Aerospike (v3.5.12), as in storage of values of a key of memory of one node.
You can also use the Java client (v3.1.7) to retrieve and write data.
I notice that with certain QPS (3K) reads (Batch) and writes.
Some of the search data does not work.
[INFO] [24/11/2015 14:43:38.782] Write Data
[ERROR] [24/11/2015 14:43:38.937] Read Data - Not Found
Has anyone encountered a similar problem?
UPDATE
I upgraded to Aerospike 3.7.1.
I am using async oparations in the following question:
public void store() {
WritePolicy expirationWritePolicy = new WritePolicy();
expirationWritePolicy.sendKey = true;
expirationWritePolicy.priority = Priority.HIGH;
expirationWritePolicy.expiration = 10;
Key key = new Key(namespace, SET_NAME, requestId);
Bin bin = new Bin(BIN_NAME, serializer.toBinary(budgetCommit));
Bin extra = new Bin("extra", "data");
client.put(expirationWritePolicy, new WriteListener() {
@Override
public void onSuccess(Key key) {
logger.info("Succeed to store {}", requestId());
}
@Override
public void onFailure(AerospikeException exception) {
logger.error(exception, "Fail to store {}", key);
}
}, key, extra, bin);
}
public void retrieve() {
WritePolicy defaultWritePolicy = new WritePolicy();
defaultWritePolicy.priority = Priority.LOW;
defaultWritePolicy.sendKey = true;
Key key = new Key(namespace, SET_NAME, requestId);
Bin closeExtra = new Bin("extra", "_closed");
client.operate(defaultWritePolicy, new RecordListener() {
@Override
public void onSuccess(Key key, Record record) {
if (record.getValue(BIN_NAME) == null){
logger.error("Fail to retrieve {}", requestId);
}
}
@Override
public void onFailure(AerospikeException exception) {
logger.error("Fail to retrieve {} : {}", requestId, exception.getMessage());
}
}, key,
Operation.append(closeExtra), Operation.get());
}
[INFO] [12/01/2016 08: 37: 16.732] Storage success 379e67dc-945d-4717-97a7-721cc8093c05 [ERROR] [12/01/2016 08: 37: 16.736] Failed to get 379e67dc-945d-4717 -97a7-721cc8093c05
The onSuccess callback is called when there is an Ack from Aerospike.
Crash triggering around 8k QPS when recording a master record.