HDFSFileSink class do not use the same configuration in master and slave

Read.Bounded<KV<LongWritable, Text>> from = Read.from(HDFSFileSource.from(options.getInputFile(), TextInputFormat.class, LongWritable.class, Text.class));
PCollection<KV<LongWritable, Text>> data = p.apply(from);
data.apply(MapElements.via(new SimpleFunction<KV<LongWritable, Text>, String>() {
    @Override
    public String apply(KV<LongWritable, Text> input) {
        return input.getValue() + "\t" + input.getValue();
    }
})).apply(Write.to(HDFSFileSink.<String>toText(options.getOutputFile())));

spark-submit --class org.apache.beam.examples.WordCountHDFS --master yarn-client   \
             ./target/word-count-beam-bundled-0.1.jar                              \
             --runner=SparkRunner                                                  \
             --inputFile=hdfs://master/tmp/input/                                  \
             --outputFile=/tmp/output/