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 <zg...@apache.org> Authored: Sun Jul 30 18:58:47 2017 +0800 Committer: Guanghao Zhang <zg...@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(); + } } }
