hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From apurt...@apache.org
Subject [5/5] hbase git commit: HBASE-17637 Update progress more frequently in IntegrationTestBigLinkedList.Generator.persist
Date Mon, 13 Feb 2017 23:15:37 GMT
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/a590f6bb
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/a590f6bb
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/a590f6bb

Branch: refs/heads/branch-1.1
Commit: a590f6bbaa74906d0b8be976b3297bfa9cd2cb22
Parents: 797e384
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:44 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/a590f6bb/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 f3d8360..849efa4 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
@@ -463,6 +463,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]);
 
@@ -485,11 +491,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();


Mime
View raw message