diff --git a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java index 83d339fefc74..a68070bf0b69 100644 --- a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java +++ b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java @@ -1171,7 +1171,7 @@ static abstract class TestBase { this.opts = options; this.status = status; this.testName = this.getClass().getSimpleName(); - everyN = (long) (opts.totalRows / (opts.totalRows * opts.sampleRate)); + everyN = (long) (1 / opts.sampleRate); if (options.isValueZipf()) { this.zipf = new RandomDistribution.Zipf(ThreadLocalRandom.current(), 1, options.getValueSize(), 1.2); @@ -2675,8 +2675,7 @@ protected static void printUsage(final String shortName, final String message) { + "Default: depend on oneCon parameter. if oneCon set to true, then connCount=1, " + "if not, connCount=thread number"); - System.err.println(" sampleRate Execute test on a sample of total " - + "rows. Only supported by randomRead. Default: 1.0"); + System.err.println(" sampleRate Execute test on a sample of total rows. Default: 1.0"); System.err.println(" period Report every 'period' rows: " + "Default: opts.perClientRunRows / 10 = " + DEFAULT_OPTS.getPerClientRunRows() / 10); System.err.println(" cycles How many times to cycle the test. Defaults: 1.");