Update SsccTransactionalTable.java use KeyValueUtil.length(c) to instead kv.getLength()
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/commit/6b0a68c9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/tree/6b0a68c9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/diff/6b0a68c9 Branch: refs/heads/master Commit: 6b0a68c9ce6308ef19d4bc0f7d0d72d6920af947 Parents: b14500c Author: mashengchen <mashengc...@gmail.com> Authored: Thu Nov 12 13:56:00 2015 +0800 Committer: mashengchen <mashengc...@gmail.com> Committed: Thu Nov 12 13:56:00 2015 +0800 ---------------------------------------------------------------------- .../hadoop/hbase/client/transactional/SsccTransactionalTable.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-trafodion/blob/6b0a68c9/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/client/transactional/SsccTransactionalTable.java ---------------------------------------------------------------------- diff --git a/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/client/transactional/SsccTransactionalTable.java b/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/client/transactional/SsccTransactionalTable.java index b4e2dec..ca952b2 100644 --- a/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/client/transactional/SsccTransactionalTable.java +++ b/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/client/transactional/SsccTransactionalTable.java @@ -701,8 +701,7 @@ if (LOG.isTraceEnabled()) LOG.trace("checkAndPut, seting request startid: " + tr if (maxKeyValueSize > 0) { for (List<Cell> list : put.getFamilyCellMap().values()) { for (Cell c : list) { - KeyValue kv = new KeyValue(c); - if (kv.getLength() > maxKeyValueSize) { + if (KeyValueUtil.length(c) > maxKeyValueSize) { throw new IllegalArgumentException("KeyValue size too large"); } }
