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:33:28 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1.2 79c8031eb -> bd86094f3


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/bd86094f
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/bd86094f
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/bd86094f

Branch: refs/heads/branch-1.2
Commit: bd86094f3c9337d88597bc01d20e775631188f12
Parents: 79c8031
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:31:27 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/bd86094f/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 a648090..ae058fb 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
@@ -1407,6 +1407,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();
+      }
     }
   }
 
@@ -1604,6 +1607,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