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 | 2 months ago
  1. 0

    Scalding Execution and PlannerException: source taps are required

    Google Groups | 2 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 | 2 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

  5. 0

    proper way of running next job in scalding

    Google Groups | 3 years ago | Neeraj Nagi
    cascading.flow.planner.PlannerException: source taps are required
  6. 0

    completely stuck with source tab error at runtime

    Google Groups | 3 years ago | Neeraj Nagi
    cascading.flow.planner.PlannerException: source taps are required

    3 unregistered visitors
    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    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