Updated Branches: refs/heads/sqoop2 66dd617da -> a52993a93
SQOOP-1036: Sqoop2: JobClient.getCounters can return NULL (Jarek Jarcec Cecho via Kate Ting) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/a52993a9 Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/a52993a9 Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/a52993a9 Branch: refs/heads/sqoop2 Commit: a52993a934cd05dbf965a04e621c6bacbc73377f Parents: 66dd617 Author: Kate Ting <[email protected]> Authored: Sat May 11 20:46:45 2013 -0400 Committer: Kate Ting <[email protected]> Committed: Sat May 11 20:46:45 2013 -0400 ---------------------------------------------------------------------- .../mapreduce/MapreduceSubmissionEngine.java | 4 ++++ 1 files changed, 4 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/a52993a9/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java ---------------------------------------------------------------------- diff --git a/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java b/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java index 6607885..02db365 100644 --- a/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java +++ b/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java @@ -402,6 +402,10 @@ public class MapreduceSubmissionEngine extends SubmissionEngine { private Counters convertMapreduceCounters(org.apache.hadoop.mapred.Counters hadoopCounters) { Counters sqoopCounters = new Counters(); + if(hadoopCounters == null) { + return sqoopCounters; + } + for(org.apache.hadoop.mapred.Counters.Group hadoopGroup : hadoopCounters) { CounterGroup sqoopGroup = new CounterGroup(hadoopGroup.getName()); for(org.apache.hadoop.mapred.Counters.Counter hadoopCounter : hadoopGroup) {
