You are viewing a plain text version of this content. The canonical link for it is here.

Posted to common-user@hadoop.apache.org by dnspies <da...@gmail.com> on 2011/12/22 11:53:45 UTC

Concurrent calls to waitForCompletion cause ClassCastException

When running a program which runs concurrent map-reduce jobs, I get a
ClassCastException if I use waitForCompletion.  (Not with submit, but I do
need the threads to wait for the jobs to complete.  Is there a way to do
that with submit?)

This example  http://old.nabble.com/file/p33022696/Main.java Main.java 
tends to throw

java.lang.ClassCastException:
org.apache.hadoop.mapreduce.lib.input.FileSplit cannot be cast to
org.apache.hadoop.mapred.InputSplit
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:411)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:371)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:210)
-- 
View this message in context: http://old.nabble.com/Concurrent-calls-to-waitForCompletion-cause-ClassCastException-tp33022696p33022696.html
Sent from the Hadoop core-user mailing list archive at Nabble.com.