Repository: sqoop Updated Branches: refs/heads/trunk 267ff3fb0 -> e077f9978
SQOOP-2712: Run only one map task attempt during export (second edition) (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/e077f997 Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/e077f997 Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/e077f997 Branch: refs/heads/trunk Commit: e077f9978343a68833e16e0fb044a687fa208aad Parents: 267ff3f Author: Kate Ting <[email protected]> Authored: Fri Dec 11 21:25:03 2015 -0800 Committer: Kate Ting <[email protected]> Committed: Fri Dec 11 21:25:03 2015 -0800 ---------------------------------------------------------------------- src/java/org/apache/sqoop/mapreduce/ExportJobBase.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/e077f997/src/java/org/apache/sqoop/mapreduce/ExportJobBase.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/sqoop/mapreduce/ExportJobBase.java b/src/java/org/apache/sqoop/mapreduce/ExportJobBase.java index 068b8f7..32de92a 100644 --- a/src/java/org/apache/sqoop/mapreduce/ExportJobBase.java +++ b/src/java/org/apache/sqoop/mapreduce/ExportJobBase.java @@ -547,7 +547,7 @@ public class ExportJobBase extends JobBase { // final table and hence re-running one mapper will lead to a misleading errors // of inserting duplicate rows. int sqoopMaxAttempts = conf.getInt(SQOOP_EXPORT_MAP_TASK_MAX_ATTEMTPS, 1); - if (sqoopMaxAttempts > 1) { + if (sqoopMaxAttempts > 0) { conf.setInt(HADOOP_MAP_TASK_MAX_ATTEMTPS, sqoopMaxAttempts); } }
