You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2015/08/28 21:28:02 UTC

[3/4] accumulo git commit: ACCUMULO-3979 make sure timers get stopped in the presence of exceptions

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 <er...@gmail.com>
Authored: Fri Aug 28 15:27:25 2015 -0400
Committer: Eric C. Newton <er...@gmail.com>
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);
     }
   }