You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by bu...@apache.org on 2017/07/31 06:17:56 UTC
[6/9] hbase git commit: HBASE-18481 The autoFlush flag was not used
in PE tool
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();
+ }
}
}