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(&quot;mapreduce.job.output.value.class&quot;,
  *    MyDbOutputFormatValueClass, Object.class);
- * myHadoopConfiguration.setClass(&quot;mapreduce.job.output.value.class&quot;,
+ * myHadoopConfiguration.setClass(&quot;mapreduce.job.partitioner.class&quot;,
  *    MyPartitionerClass, Object.class);
  * myHadoopConfiguration.setInt(&quot;mapreduce.job.reduces&quot;, 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);
 ```

Reply via email to