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:37:19 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1.1 5316580dc -> f946c0b02


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

Branch: refs/heads/branch-1.1
Commit: f946c0b02d31dd0f8428cc6672d6bccbb1118995
Parents: 5316580
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:35: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/f946c0b0/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 2e2b243..f7b7a84 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