Apache/hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-9730 Exceptions in multi operations are not handled correctly

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1530728 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Enis Soztutar 2013-10-09 17:41:54 +00:00
parent 208787b5b1
commit 7709eb393a
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
View File

@ -4043,8 +4043,6 @@ public class HRegionServer implements ClientProtos.ClientService.BlockingInterfa
try { try {
int i = 0; int i = 0;
for (ClientProtos.Action action: mutations) { for (ClientProtos.Action action: mutations) {
ClientProtos.ResultOrException.Builder resultOrExceptionBuilder =
ClientProtos.ResultOrException.newBuilder();
MutationProto m = action.getMutation(); MutationProto m = action.getMutation();
Mutation mutation; Mutation mutation;
if (m.getMutateType() == MutationType.PUT) { if (m.getMutateType() == MutationType.PUT) {
@ -4088,9 +4086,8 @@ public class HRegionServer implements ClientProtos.ClientService.BlockingInterfa
} }
} }
} catch (IOException ie) { } catch (IOException ie) {
ResultOrException resultOrException = ResponseConverter.buildActionResult(ie).build();
for (int i = 0; i < mutations.size(); i++) { for (int i = 0; i < mutations.size(); i++) {
builder.addResultOrException(resultOrException); builder.addResultOrException(getResultOrException(ie, mutations.get(i).getIndex()));
} }
} }
long after = EnvironmentEdgeManager.currentTimeMillis(); long after = EnvironmentEdgeManager.currentTimeMillis();