wchevreuil commented on a change in pull request #1623:
URL: https://github.com/apache/hbase/pull/1623#discussion_r419105596
##########
File path:
hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/mapreduce/TestSyncTable.java
##########
@@ -426,18 +451,19 @@ private Counters syncTables(TableName sourceTableName,
TableName targetTableName
return syncTable.counters;
}
- private void hashSourceTable(TableName sourceTableName, Path testDir) throws
Exception {
+ private void hashSourceTable(TableName sourceTableName, Path testDir,
String... options)
+ throws Exception {
int numHashFiles = 3;
long batchSize = 100; // should be 2 batches per region
int scanBatch = 1;
HashTable hashTable = new HashTable(TEST_UTIL.getConfiguration());
- int code = hashTable.run(new String[] {
- "--batchsize=" + batchSize,
- "--numhashfiles=" + numHashFiles,
- "--scanbatch=" + scanBatch,
- sourceTableName.getNameAsString(),
- testDir.toString()
- });
+ String[] args = Arrays.copyOf(options, options.length+5);
+ args[options.length] = "--batchsize=" + batchSize;
+ args[options.length+1] = "--numhashfiles=" + numHashFiles;
Review comment:
Indeed, fixed on latest commit.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
