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:25:28 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1.4 f309ea4c5 -> 2734543dc


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

Branch: refs/heads/branch-1.4
Commit: 2734543dc79ed437d057e829c33b9b04bffee314
Parents: f309ea4
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:26:00 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/2734543d/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 e66e133..fb6701f 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
@@ -1408,6 +1408,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();
+      }
     }
   }
 
@@ -1605,6 +1608,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