ACCUMULO-3979 make sure timers get stopped in the presence of exceptions
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/5c51b414 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/5c51b414 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/5c51b414 Branch: refs/heads/master Commit: 5c51b414ef89fc80a8941190055de1a6c21954e6 Parents: d97ff3d Author: Eric C. Newton <[email protected]> Authored: Fri Aug 28 15:27:25 2015 -0400 Committer: Eric C. Newton <[email protected]> Committed: Fri Aug 28 15:27:25 2015 -0400 ---------------------------------------------------------------------- .../main/java/org/apache/accumulo/server/client/BulkImporter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/5c51b414/server/base/src/main/java/org/apache/accumulo/server/client/BulkImporter.java ---------------------------------------------------------------------- diff --git a/server/base/src/main/java/org/apache/accumulo/server/client/BulkImporter.java b/server/base/src/main/java/org/apache/accumulo/server/client/BulkImporter.java index f9d6930..7b1bfde 100644 --- a/server/base/src/main/java/org/apache/accumulo/server/client/BulkImporter.java +++ b/server/base/src/main/java/org/apache/accumulo/server/client/BulkImporter.java @@ -255,13 +255,13 @@ public class BulkImporter { Set<Path> failedFailures = processFailures(completeFailures); assignmentStats.unrecoveredMapFiles(failedFailures); + timer.stop(Timers.TOTAL); printReport(paths); return assignmentStats; } finally { if (client != null) { ServerClient.close(client); } - timer.stop(Timers.TOTAL); } }
