HBASE-11647 MOB integration testing. - addendum(Jingcheng Du)

This commit is contained in:
anoopsjohn 2014-09-09 16:18:38 +05:30
parent 3e563c5cc7
commit 0c86d83e1f
1 changed files with 2 additions and 2 deletions

View File

@ -112,7 +112,7 @@ public class IntegrationTestIngestWithMOB extends IntegrationTestIngest {
for (HColumnDescriptor columnDescriptor : tableDesc.getFamilies()) { for (HColumnDescriptor columnDescriptor : tableDesc.getFamilies()) {
if(Arrays.equals(columnDescriptor.getName(), mobColumnFamily)) { if(Arrays.equals(columnDescriptor.getName(), mobColumnFamily)) {
columnDescriptor.setValue(MobConstants.IS_MOB, Bytes.toBytes(Boolean.TRUE)); columnDescriptor.setValue(MobConstants.IS_MOB, Bytes.toBytes(Boolean.TRUE));
columnDescriptor.setValue(MobConstants.MOB_THRESHOLD, Bytes.toBytes(threshold)); columnDescriptor.setValue(MobConstants.MOB_THRESHOLD, Bytes.toBytes((long) threshold));
admin.modifyColumn(tableName, columnDescriptor); admin.modifyColumn(tableName, columnDescriptor);
} }
} }
@ -130,7 +130,7 @@ public class IntegrationTestIngestWithMOB extends IntegrationTestIngest {
tmp.add(HIPHEN + LoadTestTool.OPT_GENERATOR); tmp.add(HIPHEN + LoadTestTool.OPT_GENERATOR);
StringBuilder sb = new StringBuilder(LoadTestDataGeneratorWithMOB.class.getName()); StringBuilder sb = new StringBuilder(LoadTestDataGeneratorWithMOB.class.getName());
sb.append(COLON); sb.append(COLON);
sb.append(mobColumnFamily); sb.append(Bytes.toString(mobColumnFamily));
sb.append(COLON); sb.append(COLON);
sb.append(minMobDataSize); sb.append(minMobDataSize);
sb.append(COLON); sb.append(COLON);