hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zg...@apache.org
Subject hbase git commit: HBASE-18481 The autoFlush flag was not used in PE tool
Date Mon, 31 Jul 2017 03:29:30 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1.3 3e450f7a0 -> d666ffc7a


HBASE-18481 The autoFlush flag was not used in PE tool


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

Branch: refs/heads/branch-1.3
Commit: d666ffc7ad014f21b32cd5d5f7666506aede30b7
Parents: 3e450f7
Author: Guanghao Zhang <zghao@apache.org>
Authored: Sun Jul 30 18:58:47 2017 +0800
Committer: Guanghao Zhang <zghao@apache.org>
Committed: Mon Jul 31 11:27:31 2017 +0800

----------------------------------------------------------------------
 .../java/org/apache/hadoop/hbase/PerformanceEvaluation.java    | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/d666ffc7/hbase-server/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java
index 281ec6f..76da965 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java
@@ -1393,6 +1393,9 @@ public class PerformanceEvaluation extends Configured implements Tool
{
       }
       put.setDurability(opts.writeToWAL ? Durability.SYNC_WAL : Durability.SKIP_WAL);
       mutator.mutate(put);
+      if (opts.autoFlush) {
+        mutator.flush();
+      }
     }
   }
 
@@ -1590,6 +1593,9 @@ public class PerformanceEvaluation extends Configured implements Tool
{
       }
       put.setDurability(opts.writeToWAL ? Durability.SYNC_WAL : Durability.SKIP_WAL);
       mutator.mutate(put);
+      if (opts.autoFlush) {
+        mutator.flush();
+      }
     }
   }
 


Mime
View raw message