Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 2015-02-04 12:47:45,300 INFO [LocalJobRunner Map Task Executor #0] mapred.Task (Task.java:initialize(581)) - Using ResourceCalculatorProcessTree : null
- 2015-02-04 12:47:45,327 INFO [LocalJobRunner Map Task Executor #0] io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/tmp/staging/data/staging-path/part-00000
- 2015-02-04 12:47:45,328 INFO [LocalJobRunner Map Task Executor #0] mapred.MapTask (MapTask.java:updateJobWithSplit(462)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@29033afe
- 2015-02-04 12:47:45,333 WARN [LocalJobRunner Map Task Executor #0] io.MultiInputFormat (Util.java:retry(768)) - unable to get record reader, but not retrying
- java.io.IOException: file:/tmp/staging/data/staging-path/part-00000 not a SequenceFile
- at org.apache.hadoop.io.SequenceFile$Reader.init(SequenceFile.java:1850)
- at org.apache.hadoop.io.SequenceFile$Reader.initialize(SequenceFile.java:1810)
- at org.apache.hadoop.io.SequenceFile$Reader.<init>(SequenceFile.java:1759)
- at org.apache.hadoop.io.SequenceFile$Reader.<init>(SequenceFile.java:1773)
- at org.apache.hadoop.mapred.SequenceFileRecordReader.<init>(SequenceFileRecordReader.java:49)
- at org.apache.hadoop.mapred.SequenceFileInputFormat.getRecordReader(SequenceFileInputFormat.java:64)
- at cascading.tap.hadoop.io.MultiInputFormat$1.operate(MultiInputFormat.java:253)
- at cascading.tap.hadoop.io.MultiInputFormat$1.operate(MultiInputFormat.java:248)
- at cascading.util.Util.retry(Util.java:762)
- at cascading.tap.hadoop.io.MultiInputFormat.getRecordReader(MultiInputFormat.java:247)
- at org.apache.hadoop.mapred.MapTask$TrackedRecordReader.<init>(MapTask.java:168)
- at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:409)
- at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
- at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
- at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
- at java.util.concurrent.FutureTask.run(FutureTask.java:266)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
- at java.lang.Thread.run(Thread.java:744)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement