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

HBASE-982 Deleting a column in MapReduce fails 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/hbase/trunk@711420 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2008-11-04 21:39:53 +00:00
parent 062e954a03
commit 8a7a750b2e
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGES.txt
View File

@ -62,6 +62,7 @@ Release 0.19.0 - Unreleased
HBASE-979 REST web app is not started automatically
HBASE-964 Startup stuck "waiting for root region"
HBASE-980 Undo core of HBASE-975, caching of start and end row
HBASE-982 Deleting a column in MapReduce fails (Doğacan Güney via Stack)
IMPROVEMENTS
HBASE-901 Add a limit to key length, check key and value length on client side

10
src/java/org/apache/hadoop/hbase/io/BatchUpdate.java
View File

@ -97,7 +97,13 @@ public class BatchUpdate implements WritableComparable<BatchUpdate>,
public BatchUpdate(BatchUpdate buToCopy) {
this(buToCopy.getRow(), buToCopy.getTimestamp());
for(BatchOperation bo : buToCopy) {
this.put(bo.getColumn(), bo.getValue());
byte [] val = bo.getValue();
if (val == null) {
// Presume a delete is intended.
this.delete(bo.getColumn());
} else {
this.put(bo.getColumn(), val);
}
}
}
@ -330,4 +336,4 @@ public class BatchUpdate implements WritableComparable<BatchUpdate>,
public int compareTo(BatchUpdate o) {
return Bytes.compareTo(this.row, o.getRow());
}
}
}