cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Benjamin Coverston (JIRA)" <>
Subject [jira] [Updated] (CASSANDRA-5201) Cassandra/Hadoop does not support current Hadoop releases
Date Tue, 03 Dec 2013 22:59:36 GMT


Benjamin Coverston updated CASSANDRA-5201:

    Attachment: hadoopCompat.patch

Poking around at other projects this generally gets solved in one of two ways: Ship two versions
of their Hadoop integrations (one compiled for the old, and one compiled for the new), or
use a little reflection to make things work across the board.

I'm attaching a patch that uses the hadoopCompat subproject of elephantbird. This will allow
us to compile a single binary and run with the new and old context objects.

I've tested this patch with HDP 2.0, and Apache Hadoop 1.0.4 and it works fine with both (including
Hive in DSE). With Pig I needed to compile our (optional) pig dependency with:

bq. ant clean jar-withouthadoop -Dhadoopversion=23

Only really needed if you're using one of the current versions of thrift with the new JobContext.

> Cassandra/Hadoop does not support current Hadoop releases
> ---------------------------------------------------------
>                 Key: CASSANDRA-5201
>                 URL:
>             Project: Cassandra
>          Issue Type: Bug
>          Components: Hadoop
>    Affects Versions: 1.2.0
>            Reporter: Brian Jeltema
>            Assignee: Dave Brosius
>         Attachments: 5201_a.txt, hadoopCompat.patch
> Using Hadoop 0.22.0 with Cassandra results in the stack trace below.
> It appears that version 0.21+ changed org.apache.hadoop.mapreduce.JobContext
> from a class to an interface.
> Exception in thread "main" java.lang.IncompatibleClassChangeError: Found interface org.apache.hadoop.mapreduce.JobContext,
but class was expected
> 	at org.apache.cassandra.hadoop.ColumnFamilyInputFormat.getSplits(
> 	at org.apache.hadoop.mapreduce.JobSubmitter.writeNewSplits(
> 	at org.apache.hadoop.mapreduce.JobSubmitter.writeSplits(
> 	at org.apache.hadoop.mapreduce.JobSubmitter.submitJobInternal(
> 	at org.apache.hadoop.mapreduce.Job$
> 	at org.apache.hadoop.mapreduce.Job$
> 	at Method)
> 	at
> 	at
> 	at org.apache.hadoop.mapreduce.Job.submit(
> 	at org.apache.hadoop.mapreduce.Job.waitForCompletion(
> 	at
> 	at
> 	at MyHadoopApp.main(
> 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke(
> 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(
> 	at java.lang.reflect.Method.invoke(
> 	at org.apache.hadoop.util.RunJar.main(

This message was sent by Atlassian JIRA

View raw message