java.lang.Throwable: GUESS: Cascading requires all sources to have final sinks on disk. App > If you know what exactly caused this error, please consider contributing to GitHub via following link. App > https://github.com/twitter/scalding/wiki/Common-Exceptions-and-possible-reasons#cascadingflowplannerplannerexception

Google Groups | ravi kiran holur vijay | 7 months ago
tip
Your exception is missing from the Samebug knowledge base.
Here are the best solutions we found on the Internet.
Click on the to mark the helpful solution and get rewards for you help.
  1. 0

    Scalding Execution and PlannerException: source taps are required

    Google Groups | 7 months ago | ravi kiran holur vijay
    java.lang.Throwable: GUESS: Cascading requires all sources to have final sinks on disk. App > If you know what exactly caused this error, please consider contributing to GitHub via following link. App > https://github.com/twitter/scalding/wiki/Common-Exceptions-and-possible-reasons#cascadingflowplannerplannerexception
  2. 0

    Cascading Text file to Parquet

    Stack Overflow | 3 years ago | user2732748
    cascading.flow.planner.PlannerException: tap named: 'Copy', cannot be used as a sink: Hfs["ParquetTupleScheme[['A', 'B']->[ALL]]"]["/user/cloudera/htcountp"]
  3. 0

    Cascading - Convert Text File to Parquet - General Discussion - Driven Forums

    driven.io | 2 years ago
    cascading.flow.planner.PlannerException: tap named: 'Copy', cannot be used as a sink: Hfs["ParquetTupleScheme[['A', 'B']->[ALL]]"]["/user/cloudera/htcountp"]
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

    3 unregistered visitors

    Root Cause Analysis

    1. cascading.flow.planner.PlannerException

      source taps are required

      at cascading.flow.planner.FlowPlanner.verifyTaps()
    2. cascading.flow.planner
      FlowPlanner.verifyAllTaps
      1. cascading.flow.planner.FlowPlanner.verifyTaps(FlowPlanner.java:234)
      2. cascading.flow.planner.FlowPlanner.verifyAllTaps(FlowPlanner.java:175)
      2 frames
    3. cascading.flow.hadoop
      HadoopPlanner.buildFlow
      1. cascading.flow.hadoop.planner.HadoopPlanner.buildFlow(HadoopPlanner.java:242)
      2. cascading.flow.hadoop.planner.HadoopPlanner.buildFlow(HadoopPlanner.java:80)
      2 frames
    4. cascading.flow
      FlowConnector.connect
      1. cascading.flow.FlowConnector.connect(FlowConnector.java:459)
      1 frame
    5. Scalding
      Job$$anonfun$buildFlow$1.apply
      1. com.twitter.scalding.ExecutionContext$class.buildFlow(ExecutionContext.scala:53)
      2. com.twitter.scalding.ExecutionContext$$anon$1.buildFlow(ExecutionContext.scala:100)
      3. com.twitter.scalding.Job$$anonfun$buildFlow$1.apply(Job.scala:225)
      4. com.twitter.scalding.Job$$anonfun$buildFlow$1.apply(Job.scala:225)
      4 frames
    6. Scala
      Success.flatMap
      1. scala.util.Success.flatMap(Try.scala:230)
      1 frame
    7. Scalding
      Tool.run
      1. com.twitter.scalding.Job.buildFlow(Job.scala:225)
      2. com.twitter.scalding.Job.run(Job.scala:295)
      3. com.twitter.scalding.Tool.start$1(Tool.scala:102)
      4. com.twitter.scalding.Tool.run(Tool.scala:118)
      5. com.twitter.scalding.Tool.run(Tool.scala:66)
      5 frames
    8. Hadoop
      ToolRunner.run
      1. org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:65)
      1 frame
    9. Scalding
      Tool.main
      1. com.twitter.scalding.Tool$.main(Tool.scala:126)
      2. com.twitter.scalding.Tool.main(Tool.scala)
      2 frames
    10. Java RT
      Method.invoke
      1. sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      2. sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
      3. sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      4. java.lang.reflect.Method.invoke(Method.java:606)
      4 frames
    11. Hadoop
      RunJar.main
      1. org.apache.hadoop.util.RunJar.main(RunJar.java:163)
      1 frame