cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Brian Jeltema <>
Subject updating CF from a mapper-only Hadoop job
Date Tue, 18 Sep 2012 14:16:14 GMT
I wrote a Hadoop mapper-only job that uses BulkOutputFormat to load a Cassandra table.
That job would consistently fail with a flurry of exceptions (primary cause looks like EOFExceptions
streaming between nodes).

I restructured the job to use an identity mapper and perform the updates in the reducer. Same
code other
be moving to the reducer. That job runs correctly.

Is this expected behavior?


View raw message