hbase-commits mailing list archives

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

Branch: refs/heads/branch-1.3
Commit: 1ecf99ecf3f2ee3d35cace7654bbc5faf628940f
Parents: a91bda9
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:04:30 2017 -0800

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


http://git-wip-us.apache.org/repos/asf/hbase/blob/1ecf99ec/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 2d828f4..4ab0a58 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
@@ -509,6 +509,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]);
 
@@ -531,12 +537,8 @@ 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