You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by ka...@apache.org on 2015/12/12 06:25:31 UTC
sqoop git commit: SQOOP-2712: Run only one map task attempt during
export (second edition) (Jarek Jarcec Cecho via Kate Ting)
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 <ka...@apache.org>
Authored: Fri Dec 11 21:25:03 2015 -0800
Committer: Kate Ting <ka...@apache.org>
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);
}
}