From 7211d13ac8763d60ce21218f0f2f36823935b40d Mon Sep 17 00:00:00 2001 From: tedyu Date: Mon, 16 Jul 2018 09:53:47 -0700 Subject: [PATCH] HBASE-20889 PE scan is failing with NullPointerException --- .../apache/hadoop/hbase/PerformanceEvaluation.java | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) 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 a67583053fe..8de5e32d622 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 @@ -1558,7 +1558,6 @@ public class PerformanceEvaluation extends Configured implements Tool { @Override void testTakedown() throws IOException { if (this.testScanner != null) { - updateScanMetrics(scan.getScanMetrics()); this.testScanner.close(); } super.testTakedown(); @@ -1568,7 +1567,7 @@ public class PerformanceEvaluation extends Configured implements Tool { @Override void testRow(final int i) throws IOException { if (this.testScanner == null) { - Scan scan = new Scan(format(opts.startRow)); + scan = new Scan(format(opts.startRow)); for (int family = 0; family < opts.families; family++) { byte[] familyName = Bytes.toBytes(FAMILY_NAME_BASE + family); if (opts.addColumns) { @@ -1587,8 +1586,12 @@ public class PerformanceEvaluation extends Configured implements Tool { scan.setScanMetricsEnabled(true); this.testScanner = table.getScanner(scan); } - Result r = testScanner.next(); - updateValueSize(r); + try { + Result r = testScanner.next(); + updateValueSize(r); + } finally { + updateScanMetrics(scan.getScanMetrics()); + } } }