diff --git a/src/main/java/com/marklogic/mapreduce/ContentOutputFormat.java b/src/main/java/com/marklogic/mapreduce/ContentOutputFormat.java
index 9e3a4a5e0..b265d3384 100644
--- a/src/main/java/com/marklogic/mapreduce/ContentOutputFormat.java
+++ b/src/main/java/com/marklogic/mapreduce/ContentOutputFormat.java
@@ -128,12 +128,12 @@ public class ContentOutputFormat<VALUEOUT> extends
       + "return if (exists($f)) then $f() else ()";
     // For HTTP Server
     public static final String HEADER_QUERY =
-        "let $f := fn:function-lookup(xs:QName('xdmp:is-forwarded'),0)\n" +
+        "let $f := fn:function-lookup(xs:QName('xdmp:request-forwarded'),0)\n" +
         "return if (exists($f)) then $f() " +
         "else fn:exists(xdmp:get-request-header('x-forwarded-for'))";
     // For XDBC Server
     public static final String XDBC_HEADER_QUERY =
-        "let $f := fn:function-lookup(xs:QName('xdmp:is-forwarded'),0)\n" +
+        "let $f := fn:function-lookup(xs:QName('xdmp:request-forwarded'),0)\n" +
         "return if (exists($f)) then $f() " +
         "else (" +
         "let $xdbcHeaderf := " +