def set_args(self, args, unknown_args=None):
if unknown_args is None:<EOL><INDENT>unknown_args = []<EOL><DEDENT>self.logger.setLevel(getattr(logging, args.log_level))<EOL>parent = hdfs.path.dirname(hdfs.path.abspath(args.output.rstrip("<STR_LIT:/>")))<EOL>self.remote_wd = hdfs.path.join(<EOL>parent, utils.make_random_str(prefix="<STR_LIT>")<EOL>)<EOL>self.remote_exe = hdfs.path.join(self.remote_wd, str(uuid.uuid4()))<EOL>self.properties[JOB_NAME] = args.job_name or '<STR_LIT>'<EOL>self.properties[IS_JAVA_RR] = (<EOL>'<STR_LIT:false>' if args.do_not_use_java_record_reader else '<STR_LIT:true>'<EOL>)<EOL>self.properties[IS_JAVA_RW] = (<EOL>'<STR_LIT:false>' if args.do_not_use_java_record_writer else '<STR_LIT:true>'<EOL>)<EOL>self.properties[JOB_REDUCES] = args.num_reducers<EOL>if args.job_name:<EOL><INDENT>self.properties[JOB_NAME] = args.job_name<EOL><DEDENT>self.properties.update(args.job_conf or {})<EOL>self.__set_files_to_cache(args)<EOL>self.__set_archives_to_cache(args)<EOL>self.requested_env = self._env_arg_to_dict(args.set_env or [])<EOL>self.args = args<EOL>self.unknown_args = unknown_args<EOL>
Configure job, based on the arguments provided.