finished -namedcode

klbostee · Nov 26, 2008 · 645ee73 · 645ee73
1 parent 17ce82a
commit 645ee73
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/python/dumbo.py b/src/python/dumbo.py
@@ -295,6 +295,8 @@ def startonstreaming(prog,opts,hadoop):
                      "dumbo.code.writable.map.streamprocessor=%s" % opt[0]))
         opts.append(("mapper",dumbopkg + ".CodeWritablePipeMapper"))
         dumbojar_needed = True
+    if addedopts["namedcode"] and addedopts["namedcode"][0] == 'yes':
+        opts.append(("jobconf", "dumbo.as.named.code=true"))
     if dumbojar_needed:
         if not dumbojar:
             print >>sys.stderr,"ERROR: Dumbo jar not found"