This is an automated email from the ASF dual-hosted git repository. aromanenko pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push: new 8af8929 [BEAM-6976] Fix incorrect doc of HadoopFormatIO on partitioner new 9521fcb Merge pull request: [BEAM-6976] Fix incorrect doc of HadoopFormatIO on partitioner 8af8929 is described below commit 8af89294935a32be1fe9c783292300b7f3b77453 Author: JohnZZGithub <johnzzgit...@users.noreply.github.com> AuthorDate: Tue Apr 2 12:10:52 2019 -0700 [BEAM-6976] Fix incorrect doc of HadoopFormatIO on partitioner wq# modified: sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/HadoopFormatIO.java --- .../main/java/org/apache/beam/sdk/io/hadoop/format/HadoopFormatIO.java | 2 +- website/src/documentation/io/built-in-hadoop.md | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/HadoopFormatIO.java b/sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/HadoopFormatIO.java index 1d7fc32..8819024 100644 --- a/sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/HadoopFormatIO.java +++ b/sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/HadoopFormatIO.java @@ -247,7 +247,7 @@ import org.slf4j.LoggerFactory; * MyDbOutputFormatKeyClass, Object.class); * myHadoopConfiguration.setClass("mapreduce.job.output.value.class", * MyDbOutputFormatValueClass, Object.class); - * myHadoopConfiguration.setClass("mapreduce.job.output.value.class", + * myHadoopConfiguration.setClass("mapreduce.job.partitioner.class", * MyPartitionerClass, Object.class); * myHadoopConfiguration.setInt("mapreduce.job.reduces", 2); * }</pre> diff --git a/website/src/documentation/io/built-in-hadoop.md b/website/src/documentation/io/built-in-hadoop.md index 37ae66f..fd330ec 100644 --- a/website/src/documentation/io/built-in-hadoop.md +++ b/website/src/documentation/io/built-in-hadoop.md @@ -376,7 +376,7 @@ myHadoopConfiguration.setClass("mapreduce.job.output.key.class", MyDbOutputFormatKeyClass, Object.class); myHadoopConfiguration.setClass("mapreduce.job.output.value.class", MyDbOutputFormatValueClass, Object.class); -myHadoopConfiguration.setClass("mapreduce.job.output.value.class", +myHadoopConfiguration.setClass("mapreduce.job.partitioner.class", MyPartitionerClass, Object.class); myHadoopConfiguration.setInt("mapreduce.job.reduces", 2); ```