13/11/13 12:41:22 INFO util.HadoopUtil: resolving application jar from found main method on: com.twitter.scalding.Tool$
13/11/13 12:41:22 INFO planner.HadoopPlanner: using application jar: /home/mping/scalding-core-assembly-0.9.0rc4.jar
13/11/13 12:41:22 INFO property.AppProps: using
app.id: 121717910EA64318974CF905E9967174
Exception in thread "main" java.lang.Throwable: GUESS: Cascading requires all sources to have final sinks on disk.
If you know what exactly caused this error, please consider contributing to GitHub via following link.
at com.twitter.scalding.Tool$.main(Tool.scala:154)
at com.twitter.scalding.Tool.main(Tool.scala)
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:208)
Caused by: cascading.flow.planner.PlannerException: could not build flow from assembly: [null]
at cascading.flow.planner.FlowPlanner.handleExceptionDuringPlanning(FlowPlanner.java:576)
at cascading.flow.hadoop.planner.HadoopPlanner.buildFlow(HadoopPlanner.java:263)
at cascading.flow.hadoop.planner.HadoopPlanner.buildFlow(HadoopPlanner.java:80)
at cascading.flow.FlowConnector.connect(FlowConnector.java:459)
at com.twitter.scalding.Job.buildFlow(Job.scala:205)
at com.twitter.scalding.Job.runFlow(Job.scala:226)
at com.twitter.scalding.Job.run(Job.scala:232)
at com.twitter.scalding.Tool.start$1(Tool.scala:114)
at com.twitter.scalding.Tool.run(Tool.scala:132)
at com.twitter.scalding.Tool.run(Tool.scala:70)
at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:70)
at com.twitter.scalding.Tool$.main(Tool.scala:140)
... 6 more
Caused by: java.lang.NullPointerException
at cascading.tap.hadoop.io.MultiInputFormat.addInputFormat(MultiInputFormat.java:76)
at cascading.flow.hadoop.HadoopFlowStep.initFromSources(HadoopFlowStep.java:345)
at cascading.flow.hadoop.HadoopFlowStep.getInitializedConfig(HadoopFlowStep.java:99)
at cascading.flow.hadoop.HadoopFlowStep.createFlowStepJob(HadoopFlowStep.java:201)
at cascading.flow.hadoop.HadoopFlowStep.createFlowStepJob(HadoopFlowStep.java:69)
at cascading.flow.planner.BaseFlowStep.getFlowStepJob(BaseFlowStep.java:676)
at cascading.flow.BaseFlow.initializeNewJobsMap(BaseFlow.java:1181)
at cascading.flow.BaseFlow.initialize(BaseFlow.java:199)
at cascading.flow.hadoop.planner.HadoopPlanner.buildFlow(HadoopPlanner.java:257)
... 16 more