allow fallback in heartbeat when the task id is lacking

relates to #148
elastic · Apr 8, 2014 · f52c6db · f52c6db
1 parent 89eaf27
commit f52c6db
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/src/main/java/org/elasticsearch/hadoop/mr/HeartBeat.java b/src/main/java/org/elasticsearch/hadoop/mr/HeartBeat.java
@@ -50,14 +50,16 @@ class HeartBeat {
         this.log = log;
         TaskID taskID = TaskID.forName(HadoopCfgUtils.getTaskId(cfg));
 
+        String taskId;
         if (taskID == null) {
-            log.error(String.format("Cannot determine task id - current properties are %s", HadoopCfgUtils.asProperties(cfg)));
+            log.warn("Cannot determine task id...");
+            taskId = "<unknown>";
+        }
+        else {
+            taskId = "" + taskID.getId();
         }
 
-        Assert.notNull(taskID,
-                "Unable to determine task id - please report your distro/setting through the issue tracker");
-
-        this.id = taskID.toString();
+        id = taskId;
     }