hbase-commits mailing list archives

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


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/33911c5e
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/33911c5e
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/33911c5e

Branch: refs/heads/branch-1.2
Commit: 33911c5ed5bf712baaad87fbe11a7baca3d63f07
Parents: 77d6049
Author: Andrew Purtell <apurtell@apache.org>
Authored: Mon Feb 13 15:04:15 2017 -0800
Committer: Andrew Purtell <apurtell@apache.org>
Committed: Mon Feb 13 15:05:22 2017 -0800

----------------------------------------------------------------------
 .../hadoop/hbase/test/IntegrationTestBigLinkedList.java  | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/33911c5e/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java
----------------------------------------------------------------------
diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java
b/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java
index 7f0f732..91f99f1 100644
--- a/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java
+++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.java
@@ -462,6 +462,12 @@ public class IntegrationTestBigLinkedList extends IntegrationTestBase
{
       protected void persist(Context output, long count, byte[][] prev, byte[][] current,
byte[] id)
           throws IOException {
         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.addColumn(FAMILY_NAME, COLUMN_PREV, prev == null ? NO_KEY : prev[i]);
 
@@ -484,11 +490,6 @@ public class IntegrationTestBigLinkedList extends IntegrationTestBase
{
             put.addColumn(BIG_FAMILY_NAME, BIG_FAMILY_NAME, this.bigValue);
           }
           mutator.mutate(put);
-
-          if (i % 1000 == 0) {
-            // Tickle progress every so often else maprunner will think us hung
-            output.progress();
-          }
         }
 
         mutator.flush();