accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject accumulo git commit: ACCUMULO-4123 increment the counters properly
Date Tue, 02 Feb 2016 15:39:39 GMT
Repository: accumulo
Updated Branches:
  refs/heads/master f1523abd5 -> 24ee37f90


ACCUMULO-4123 increment the counters properly


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/24ee37f9
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/24ee37f9
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/24ee37f9

Branch: refs/heads/master
Commit: 24ee37f90417b88f791c1d3b395cc8ad479e01ba
Parents: f1523ab
Author: Eric C. Newton <eric.newton@gmail.com>
Authored: Tue Feb 2 10:39:29 2016 -0500
Committer: Eric C. Newton <eric.newton@gmail.com>
Committed: Tue Feb 2 10:39:29 2016 -0500

----------------------------------------------------------------------
 .../apache/accumulo/test/mrit/IntegrationTestMapReduce.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/24ee37f9/test/src/main/java/org/apache/accumulo/test/mrit/IntegrationTestMapReduce.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/mrit/IntegrationTestMapReduce.java
b/test/src/main/java/org/apache/accumulo/test/mrit/IntegrationTestMapReduce.java
index 62b82c9..ee8d7b3 100644
--- a/test/src/main/java/org/apache/accumulo/test/mrit/IntegrationTestMapReduce.java
+++ b/test/src/main/java/org/apache/accumulo/test/mrit/IntegrationTestMapReduce.java
@@ -103,7 +103,7 @@ public class IntegrationTestMapReduce extends Configured implements Tool
{
         test = Class.forName(className);
       } catch (ClassNotFoundException e) {
         log.debug("Error finding class {}", className, e);
-        context.getCounter(TestCounts.ERROR);
+        context.getCounter(TestCounts.ERROR).increment(1);
         context.write(ERROR, new Text(e.toString()));
         return;
       }
@@ -136,11 +136,11 @@ public class IntegrationTestMapReduce extends Configured implements
Tool {
         Result result = core.run(test);
         if (result.wasSuccessful()) {
           log.info("{} was successful", className);
-          context.getCounter(TestCounts.PASS);
+          context.getCounter(TestCounts.PASS).increment(1);
           context.write(PASS, value);
         } else {
           log.info("{} failed", className);
-          context.getCounter(TestCounts.FAIL);
+          context.getCounter(TestCounts.FAIL).increment(1);
           context.write(FAIL, new Text(className + "(" + StringUtils.join(failures, ", ")
+ ")"));
         }
       } catch (Exception e) {


Mime
View raw message