gistfile1.txt

Tarragon:logparser dan$ hadoop jar build/logparser.jar data/apache.200.txt logparser-output
09/08/28 12:54:29 INFO flow.MultiMapReducePlanner: using application jar: /Users/dan/Downloads/logparser/build/logparser.jar
09/08/28 12:54:29 INFO flow.Flow: [parser] starting
09/08/28 12:54:29 INFO flow.Flow: [parser]  source: Lfs["TextLine[['offset', 'line']->[ALL]]"]["data/apache.200.txt"]"]
09/08/28 12:54:29 INFO flow.Flow: [parser]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["logparser-output"]"]
Exception in thread "main" cascading.flow.FlowException: unhandled exception
        at cascading.flow.Flow.complete(Flow.java:646)
        at logparser.Main.main(Unknown Source)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
        at java.lang.reflect.Method.invoke(Method.java:597)
        at org.apache.hadoop.util.RunJar.main(RunJar.java:156)
Caused by: java.lang.RuntimeException: java.io.IOException: Call to localhost/127.0.0.1:9000 failed on local exception: java.io.EOFException
        at org.apache.hadoop.mapred.JobConf.getWorkingDirectory(JobConf.java:436)
        at org.apache.hadoop.mapred.FileInputFormat.addInputPath(FileInputFormat.java:327)
        at cascading.tap.Hfs.sourceInit(Hfs.java:292)
        at cascading.flow.FlowStep.initFromSources(FlowStep.java:234)
        at cascading.flow.FlowStep.getJobConf(FlowStep.java:152)
        at cascading.flow.FlowStep.getFlowStepJob(FlowStep.java:417)
        at cascading.flow.Flow.initializeNewJobsMap(Flow.java:931)
        at cascading.flow.Flow.run(Flow.java:840)
        at java.lang.Thread.run(Thread.java:637)
Caused by: java.io.IOException: Call to localhost/127.0.0.1:9000 failed on local exception: java.io.EOFException
        at org.apache.hadoop.ipc.Client.wrapException(Client.java:774)
        at org.apache.hadoop.ipc.Client.call(Client.java:742)
        at org.apache.hadoop.ipc.RPC$Invoker.invoke(RPC.java:220)
        at $Proxy0.getProtocolVersion(Unknown Source)
        at org.apache.hadoop.ipc.RPC.getProxy(RPC.java:359)
        at org.apache.hadoop.hdfs.DFSClient.createRPCNamenode(DFSClient.java:105)
        at org.apache.hadoop.hdfs.DFSClient.<init>(DFSClient.java:177)
        at org.apache.hadoop.hdfs.DistributedFileSystem.initialize(DistributedFileSystem.java:82)
        at org.apache.hadoop.fs.FileSystem.createFileSystem(FileSystem.java:1373)
        at org.apache.hadoop.fs.FileSystem.access$200(FileSystem.java:66)
        at org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:1385)
        at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:191)
        at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:95)
        at org.apache.hadoop.mapred.JobConf.getWorkingDirectory(JobConf.java:432)
        ... 8 more
Caused by: java.io.EOFException
        at java.io.DataInputStream.readInt(DataInputStream.java:375)
        at org.apache.hadoop.ipc.Client$Connection.receiveResponse(Client.java:501)
        at org.apache.hadoop.ipc.Client$Connection.run(Client.java:446)