[
https://issues.apache.org/jira/browse/KAFKA-934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-934:
--------------------------------
Fix Version/s: (was: 0.8.1)
0.8.2
> kafka hadoop consumer and producer use older 0.19.2 hadoop api's
> ----------------------------------------------------------------
>
> Key: KAFKA-934
> URL: https://issues.apache.org/jira/browse/KAFKA-934
> Project: Kafka
> Issue Type: Bug
> Components: contrib
> Affects Versions: 0.8.0
> Environment: [amilkowski@localhost impl]$ uname -a
> Linux localhost.localdomain 3.9.4-200.fc18.x86_64 #1 SMP Fri May 24 20:10:49
> UTC 2013 x86_64 x86_64 x86_64 GNU/Linux
> Reporter: Andrew Milkowski
> Labels: hadoop, hadoop-2.0, newbie
> Fix For: 0.8.2
>
>
> New hadoop api present in 0.20.1 especially package
> org.apache.hadoop.mapredude.lib is not used
> code affected is both consumer and producer in kafka in the contrib package
> [amilkowski@localhost contrib]$ pwd
> /opt/local/git/kafka/contrib
> [amilkowski@localhost contrib]$ ls -lt
> total 12
> drwxrwxr-x 8 amilkowski amilkowski 4096 May 30 11:14 hadoop-consumer
> drwxrwxr-x 6 amilkowski amilkowski 4096 May 29 19:31 hadoop-producer
> drwxrwxr-x 6 amilkowski amilkowski 4096 May 29 16:43 target
> [amilkowski@localhost contrib]$
> in example
> import org.apache.hadoop.mapred.JobClient;
> import org.apache.hadoop.mapred.JobConf;
> import org.apache.hadoop.mapred.RunningJob;
> import org.apache.hadoop.mapred.TextOutputFormat;
> use 0.19.2 hadoop api format, this prevents merging of hadoop feature into
> more modern hadoop implementation
> instead of drawing from 0.20.1 api set in import org.apache.hadoop.mapreduce
--
This message was sent by Atlassian JIRA
(v6.1.5#6160)
