diff --git a/spring-data-riak/src/test/groovy/org/springframework/data/keyvalue/riak/core/RiakBuilderSpec.groovy b/spring-data-riak/src/test/groovy/org/springframework/data/keyvalue/riak/core/RiakBuilderSpec.groovy
index 692d49e73..f7efc4f8a 100644
--- a/spring-data-riak/src/test/groovy/org/springframework/data/keyvalue/riak/core/RiakBuilderSpec.groovy
+++ b/spring-data-riak/src/test/groovy/org/springframework/data/keyvalue/riak/core/RiakBuilderSpec.groovy
@@ -245,10 +245,10 @@ class RiakBuilderSpec extends Specification {
         inputs "test"
         query {
           map(arg: [test: "arg", alist: [1, 2, 3, 4]]) {
-            source "function(v, keyInfo, arg){ ejsLog('/tmp/mapred.log', JSON.stringify(v)); ejsLog('/tmp/mapred.log', JSON.stringify(keyInfo)); ejsLog('/tmp/mapred.log', JSON.stringify(arg)); return [1]; }"
+            source "function(v, keyInfo, arg){ return [1]; }"
           }
           reduce {
-            source "function(v){ ejsLog('/tmp/mapred.log', JSON.stringify(arguments)); return Riak.reduceSum(v); }"
+            source "function(v){ return Riak.reduceSum(v); }"
           }
         }
         completed { it }