You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
new: in master and since tag v3.10.9-internal9 for (K key : batch.getKeys()) { latest.remove(key); } before: for (SingleOperation<K, V> op : operations()) { latest.remove(op.getKey(), op); }
I would like to know why you changed it back. Are there any special considerations? Thank you!
The text was updated successfully, but these errors were encountered:
BatchingLocalHeapWriteBehindQueue:
public void run() {
List<BatchOperation<K, V>> batches = createMonomorphicBatches(operations());
// execute the batch operations
for (BatchOperation<K, V> batch : batches) {
try {
try {
batch.performOperation(cacheLoaderWriter);
} finally {
try {
for (K key : batch.getKeys()) {
latest.remove(key);
}
} finally {
LOGGER.debug("Cancelling batch expiry task");
expireTask.cancel(false);
}
}
}
catch (Exception ex) {
for (K key : batch.getKeys()) {
keyCleanUpMethod.accept(key);
}
LOGGER.warn("Exception while bulk processing in write behind queue", ex);
}
}
}
new: in master and since tag v3.10.9-internal9
for (K key : batch.getKeys()) { latest.remove(key); }
before:
for (SingleOperation<K, V> op : operations()) { latest.remove(op.getKey(), op); }
I would like to know why you changed it back. Are there any special considerations? Thank you!
The text was updated successfully, but these errors were encountered: