Details
-
Bug
-
Status: Resolved
-
P3
-
Resolution: Fixed
-
2.10.0, 2.11.0
Description
Here's the current doc
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", MyPartitionerClass, Object.class);
It should be myHadoopConfiguration.setClass("mapreduce.job.partitioner.class",
MyPartitionerClass, Object.class);
The error are found in both website/src/documentation/io/built-in-hadoop.md and sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/HadoopFormatIO.java
Attachments
Issue Links
- links to