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 | 4 months ago
tip
Click on the to mark the solution that helps you, Samebug will learn from it.
As a community member, you’ll be rewarded for you help.
  1. 0

    Scalding Execution and PlannerException: source taps are required

    Google Groups | 4 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 | 1 year 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