accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject [1/2] accumulo git commit: ACCUMULO-3933 mark map-reduce status
Date Wed, 08 Jul 2015 15:52:43 GMT
Repository: accumulo
Updated Branches:
  refs/heads/master 5cb22b395 -> a7021b67b


ACCUMULO-3933 mark map-reduce status


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

Branch: refs/heads/master
Commit: f4b0a07e450ad2e16aa8aacf6436d6b582324bed
Parents: 55a6d3e
Author: Eric C. Newton <eric.newton@gmail.com>
Authored: Wed Jul 8 11:52:23 2015 -0400
Committer: Eric C. Newton <eric.newton@gmail.com>
Committed: Wed Jul 8 11:52:23 2015 -0400

----------------------------------------------------------------------
 .../org/apache/accumulo/test/mrit/IntegrationTestMapReduce.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/f4b0a07e/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 7ecf02a..eb8a813 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
@@ -88,11 +88,11 @@ public class IntegrationTestMapReduce extends Configured implements Tool
{
 
     @Override
     protected void map(LongWritable key, Text value, final Mapper<LongWritable,Text,Text,Text>.Context
context) throws IOException, InterruptedException {
+      isMapReduce = true;
       String className = value.toString();
       if (className.trim().isEmpty()) {
         return;
       }
-      log.info("Running test {}", className);
       final List<String> failures = new ArrayList<>();
       Class<? extends Object> test = null;
       try {
@@ -102,6 +102,7 @@ public class IntegrationTestMapReduce extends Configured implements Tool
{
         context.write(ERROR, new Text(e.toString()));
         return;
       }
+      log.info("Running test {}", className);
       JUnitCore core = new JUnitCore();
       core.addListener(new RunListener() {
 


Mime
View raw message