diff --git a/core/src/main/java/com/yahoo/ycsb/workloads/CoreWorkload.java b/core/src/main/java/com/yahoo/ycsb/workloads/CoreWorkload.java index 2a145125be2d84ef6aa832a2eb0640b6b7e399d7..ac625b74dda1395bad58e92dc2431135ce3a3e65 100644 --- a/core/src/main/java/com/yahoo/ycsb/workloads/CoreWorkload.java +++ b/core/src/main/java/com/yahoo/ycsb/workloads/CoreWorkload.java @@ -760,10 +760,13 @@ public class CoreWorkload extends Workload //choose the next key int keynum=transactioninsertkeysequence.nextInt(); - String dbkey = buildKeyName(keynum); + try { + String dbkey = buildKeyName(keynum); - HashMap<String, ByteIterator> values = buildValues(dbkey); - db.insert(table,dbkey,values); - transactioninsertkeysequence.acknowledge(keynum); + HashMap<String, ByteIterator> values = buildValues(dbkey); + db.insert(table,dbkey,values); + } finally { + transactioninsertkeysequence.acknowledge(keynum); + } } }