hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bus...@apache.org
Subject [6/9] hbase git commit: HBASE-18481 The autoFlush flag was not used in PE tool
Date Mon, 31 Jul 2017 06:17:56 GMT
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/df90ba58
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/df90ba58
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/df90ba58

Branch: refs/heads/HBASE-18426
Commit: df90ba58db8ce6d6e6bead0c8a5cb2d1a1ad3195
Parents: 00c1b56
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 10:54:45 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/df90ba58/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 cabbdb4..d6f0af9 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
@@ -1466,6 +1466,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();
+      }
     }
   }
 
@@ -1664,6 +1667,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