Update SingleVersionDeleteNotSupported.java use cell.getTypeByte instead of constructing a new object kv
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/commit/bdc8c10e Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/tree/bdc8c10e Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/diff/bdc8c10e Branch: refs/heads/master Commit: bdc8c10ea5e78cb8f81fc4935d1a8fdbef8c9a6a Parents: dd2ea96 Author: mashengchen <mashengc...@gmail.com> Authored: Thu Nov 12 11:26:05 2015 +0800 Committer: mashengchen <mashengc...@gmail.com> Committed: Thu Nov 12 11:26:05 2015 +0800 ---------------------------------------------------------------------- .../transactional/SingleVersionDeleteNotSupported.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-trafodion/blob/bdc8c10e/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/regionserver/transactional/SingleVersionDeleteNotSupported.java ---------------------------------------------------------------------- diff --git a/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/regionserver/transactional/SingleVersionDeleteNotSupported.java b/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/regionserver/transactional/SingleVersionDeleteNotSupported.java index 7d1157e..6cd6743 100755 --- a/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/regionserver/transactional/SingleVersionDeleteNotSupported.java +++ b/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/regionserver/transactional/SingleVersionDeleteNotSupported.java @@ -57,8 +57,7 @@ public class SingleVersionDeleteNotSupported extends DoNotRetryIOException { Collection<List<Cell>> values = delete.getFamilyCellMap().values(); for (List<Cell> value : values) { for (Cell cell : value) { - KeyValue kv = new KeyValue(cell); - if (Type.Delete.getCode() == kv.getTypeByte()) { + if (cell.getTypeByte() == Type.Delete.getCode()) { throw new SingleVersionDeleteNotSupported(); } }