Allow retries for ES export.

pulquero · Jan 23, 2025 · 5befed8 · 5befed8
1 parent 229fda5
commit 5befed8
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/tools/src/main/java/com/msd/gin/halyard/tools/HalyardBulkExport.java b/tools/src/main/java/com/msd/gin/halyard/tools/HalyardBulkExport.java
@@ -346,7 +346,9 @@ private static List<JsonInfo> run(Configuration conf, String queryFiles, String
         BindingSet bindings = AbstractHalyardTool.getBindings(conf, SimpleValueFactory.getInstance());
         Job job = Job.getInstance(conf, "HalyardBulkExport " + source + " -> " + target);
         job.setJarByClass(HalyardBulkExport.class);
-        job.setMaxMapAttempts(1);
+        if (!isEsExport) {
+        	job.setMaxMapAttempts(1);
+        }
         job.setMapperClass(BulkExportMapper.class);
         job.setMapOutputKeyClass(NullWritable.class);
         job.setNumReduceTasks(0);