Added try-catch block to prevent driver from stopping
@@ -611,6 +611,7 @@ public class IgniteCacheRandomOperationBenchmark extends IgniteAbstractBenchmark
private void executeRandomOperation(Map<Object, Object> map, IgniteCache<Object, Object> cache) throws Exception {
Operation op = nextRandomOperation();
+ try {
switch (op) {
case PUT:
doPut(cache);
@@ -663,8 +664,13 @@ public class IgniteCacheRandomOperationBenchmark extends IgniteAbstractBenchmark
case CONTINUOUS_QUERY:
doContinuousQuery(cache, map);
}
+
storeStatistics(cache.getName(), map, op);
}
+ catch (Exception e){
+ BenchmarkUtils.error(String.format("Failed to perform operation %s.", op), e);
+ }
+ }
/**
* @return Operation.
