diff --git a/mrjob/inline.py b/mrjob/inline.py index d66335989..84b683042 100644 --- a/mrjob/inline.py +++ b/mrjob/inline.py @@ -18,6 +18,7 @@ import logging import os from io import BytesIO +from shutil import copyfile from mrjob.job import MRJob from mrjob.parse import parse_mr_job_stderr @@ -117,6 +118,11 @@ def _run_step(self, step_num, step_type, input_path, output_path, working_dir, env, child_stdin=None): step = self._get_step(step_num) + # if no mapper, just pass the data through (see #1141) + if step_type == 'mapper' and not step.get('mapper'): + copyfile(input_path, output_path) + return + # Passing local=False ensures the job uses proper names for file # options (see issue #851 on github) common_args = (['--step-num=%d' % step_num] +