diff --git src/java/org/apache/nutch/crawl/GeneratorJob.java src/java/org/apache/nutch/crawl/GeneratorJob.java
--- src/java/org/apache/nutch/crawl/GeneratorJob.java
+++ src/java/org/apache/nutch/crawl/GeneratorJob.java
@@ -161,6 +161,11 @@
   }
 
   public Map<String,Object> run(Map<String,Object> args) throws Exception {
+    String batchId = (String)args.get(Nutch.ARG_BATCH);
+    if (batchId != null) {
+      getConf().set(GeneratorJob.BATCH_ID, batchId);
+    }
+    
     // map to inverted subset due for fetch, sort by score
     Long topN = (Long)args.get(Nutch.ARG_TOPN);
     Long curTime = (Long)args.get(Nutch.ARG_CURTIME);