diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java index a702b52..a0a5446 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java @@ -4020,8 +4020,6 @@ public class HRegionServer implements ClientProtos.ClientService.BlockingInterfa try { int i = 0; for (ClientProtos.Action action: mutations) { - ClientProtos.ResultOrException.Builder resultOrExceptionBuilder = - ClientProtos.ResultOrException.newBuilder(); MutationProto m = action.getMutation(); Mutation mutation; if (m.getMutateType() == MutationType.PUT) { @@ -4065,9 +4063,8 @@ public class HRegionServer implements ClientProtos.ClientService.BlockingInterfa } } } catch (IOException ie) { - ResultOrException resultOrException = ResponseConverter.buildActionResult(ie).build(); for (int i = 0; i < mutations.size(); i++) { - builder.addResultOrException(resultOrException); + builder.addResultOrException(getResultOrException(ie, mutations.get(i).getIndex())); } } long after = EnvironmentEdgeManager.currentTimeMillis();