diff --git a/vitess/src/main/java/com/yahoo/ycsb/db/VitessClient.java b/vitess/src/main/java/com/yahoo/ycsb/db/VitessClient.java index 68bb2fa154..39541d588c 100644 --- a/vitess/src/main/java/com/yahoo/ycsb/db/VitessClient.java +++ b/vitess/src/main/java/com/yahoo/ycsb/db/VitessClient.java @@ -139,7 +139,7 @@ private Status applyMutation(QueryCreator.Query query) { tx.executeKeyspaceIds( ctx, query.getQuery(), query.getKeyspace(), query.getKeyspaceId(), query.getBindVars(), query.getTabletType()).checkedGet(); - tx.commit(ctx); + tx.commit(ctx).checkedGet(); } } catch (Exception e) { e.printStackTrace();