TypeError: run() got an unexpected keyword argument 'mapper_params'

[ghost]

Hi,
I'm getting this error when running word count. I couldn't find resources related to this error.

TypeError: run() got an unexpected keyword argument 'mapper_params'
WARNING  2016-04-27 22:04:38,284 pipeline.py:2593] Giving up on pipeline ID "4cb04809e81945dca604e2aa78e0cfce" after 3 attempt(s); causing abort all the way to the root pipeline ID "63400f755614406d9b46873e1a10cac2"
INFO     2016-04-27 22:04:38,296 module.py:787] default: "POST /mapreduce/pipeline/run HTTP/1.1" 200 -
INFO     2016-04-27 22:04:38,325 module.py:787] default: "POST /mapreduce/pipeline/fanout_abort HTTP/1.1" 200 -
INFO     2016-04-27 22:04:38,365 module.py:787] default: "POST /mapreduce/pipeline/abort HTTP/1.1" 200 -
WARNING  2016-04-27 22:04:38,381 pipeline.py:935] Could not send result email for root pipeline ID "63400f755614406d9b46873e1a10cac2" from sender "<project-id>@<project-id>.appspotmail.com"
INFO     2016-04-27 22:04:38,395 module.py:787] default: "POST /mapreduce/pipeline/abort HTTP/1.1" 200 -

Thanks