Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-17637 Update progress more frequently in IntegrationTestBigLinkedList.Generator.persist

This commit is contained in:
Andrew Purtell 2017-02-13 15:04:15 -08:00
parent 55c2e2d484
commit 915928287f
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java
View File

@ -507,6 +507,12 @@ public class IntegrationTestBigLinkedList extends IntegrationTestBase {
protected void persist(Context output, long count, byte[][] prev, byte[][] current, byte[] id) protected void persist(Context output, long count, byte[][] prev, byte[][] current, byte[] id)
throws IOException { throws IOException {
for (int i = 0; i < current.length; i++) { for (int i = 0; i < current.length; i++) {
if (i % 100 == 0) {
// Tickle progress every so often else maprunner will think us hung
output.progress();
}
Put put = new Put(current[i]); Put put = new Put(current[i]);
put.addColumn(FAMILY_NAME, COLUMN_PREV, prev == null ? NO_KEY : prev[i]); put.addColumn(FAMILY_NAME, COLUMN_PREV, prev == null ? NO_KEY : prev[i]);
@ -529,12 +535,8 @@ public class IntegrationTestBigLinkedList extends IntegrationTestBase {
put.addColumn(BIG_FAMILY_NAME, BIG_FAMILY_NAME, this.bigValue); put.addColumn(BIG_FAMILY_NAME, BIG_FAMILY_NAME, this.bigValue);
} }
mutator.mutate(put); mutator.mutate(put);
if (i % 1000 == 0) {
// Tickle progress every so often else maprunner will think us hung
output.progress();
}
} }
mutator.flush(); mutator.flush();
} }