You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by en...@apache.org on 2013/10/09 19:41:55 UTC
svn commit: r1530728 -
/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
Author: enis
Date: Wed Oct 9 17:41:54 2013
New Revision: 1530728
URL: http://svn.apache.org/r1530728
Log:
HBASE-9730 Exceptions in multi operations are not handled correctly
Modified:
hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java?rev=1530728&r1=1530727&r2=1530728&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java (original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java Wed Oct 9 17:41:54 2013
@@ -4043,8 +4043,6 @@ public class HRegionServer implements Cl
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) {
@@ -4088,9 +4086,8 @@ public class HRegionServer implements Cl
}
}
} 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();