Skip to content
Snippets Groups Projects
Commit 96eaa580 authored by Sean Busbey's avatar Sean Busbey
Browse files

Merge pull request #188 from y0un5/fix-hbase-update

Fix hbase client's write bug in debug mode.
parents dfc2555c c57ea785
No related branches found
No related tags found
No related merge requests found
......@@ -316,11 +316,12 @@ public class HBaseClient extends com.yahoo.ycsb.DB
Put p = new Put(Bytes.toBytes(key));
for (Map.Entry<String, ByteIterator> entry : values.entrySet())
{
byte[] value = entry.getValue().toArray();
if (_debug) {
System.out.println("Adding field/value " + entry.getKey() + "/"+
entry.getValue() + " to put request");
Bytes.toStringBinary(value) + " to put request");
}
p.add(_columnFamilyBytes,Bytes.toBytes(entry.getKey()),entry.getValue().toArray());
p.add(_columnFamilyBytes,Bytes.toBytes(entry.getKey()), value);
}
try
......
......@@ -372,11 +372,12 @@ public class HBaseClient10 extends com.yahoo.ycsb.DB
p.setDurability(_durability);
for (Map.Entry<String, ByteIterator> entry : values.entrySet())
{
byte[] value = entry.getValue().toArray();
if (_debug) {
System.out.println("Adding field/value " + entry.getKey() + "/"+
entry.getValue() + " to put request");
Bytes.toStringBinary(value) + " to put request");
}
p.add(_columnFamilyBytes,Bytes.toBytes(entry.getKey()),entry.getValue().toArray());
p.add(_columnFamilyBytes,Bytes.toBytes(entry.getKey()), value);
}
try
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment