cascading.flow.planner.PlannerException: registry: MapReduceHadoopRuleRegistry, phase: PostPipelines, failed on rule: RemoveMalformedHashJoinPipelineTransformer, see attached source element-graph

Google Groups | Shishir Adhikari | 4 months ago
  1. 0

    IllegalStateException: too many captured primary elements -- Exception in thread "main" cascading.flow.planner.PlannerException: registry: MapReduceHadoopRuleRegistry, phase: PostPipelines, failed on rule: RemoveMalformedHashJoinPipelineTransformer

    Google Groups | 4 months ago | Shishir Adhikari
    cascading.flow.planner.PlannerException: registry: MapReduceHadoopRuleRegistry, phase: PostPipelines, failed on rule: RemoveMalformedHashJoinPipelineTransformer, see attached source element-graph
  2. 0

    PlannerException: union of steps have 3 fewer elements than parent assembly

    Google Groups | 1 year ago | PUSHPAK GOHEY
    cascading.flow.planner.PlannerException: union of steps have 3 fewer elements than parent assembly: MapReduceHadoopRuleRegistry, missing: [Hfs["TextDelimited[['f1', 'f2', 'f3']]"]["../cascading-platform/src/test/resources/data/delimited-file1.txt"], Every(GroupBy Pipe 1)[First[decl:ARGS]], GroupBy(GroupBy Pipe 1)[by:[{1}:'f1']]]
  3. 0

    Hash join fails giving PlannerException when same input file are used multiple time

    Google Groups | 3 months ago | santlal gupta
    cascading.flow.planner.PlannerException: no pipelines partitioned from node: MapReduceHadoopRuleRegistry*
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    GitHub comment 1592#246148101

    GitHub | 3 months ago | johnynek
    cascading.flow.planner.PlannerException: union of steps have 1 fewer elements than parent assembly: MapReduceHadoopRuleRegistry, missing: [Each(_pipe_4+_pipe_5)[Identity[decl:'id', 'count']]]
  6. 0

    Missing commit in Cascading 3.2-wip3?

    Google Groups | 3 months ago | Piyush Narang
    cascading.flow.planner.PlannerException: union of steps have 1 fewer elements than parent assembly: MapReduceHadoopRuleRegistry, missing: [Each(_pipe_0+_pipe_1)[FlatMapFunction[decl:'mergeError']]]

    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. java.lang.IllegalStateException

      too many captured primary elements

      at cascading.flow.planner.iso.transformer.RemoveBranchGraphTransformer.transformGraphInPlaceUsing()
    2. cascading.flow.planner
      RuleSetExec$3.call
      1. cascading.flow.planner.iso.transformer.RemoveBranchGraphTransformer.transformGraphInPlaceUsing(RemoveBranchGraphTransformer.java:58)
      2. cascading.flow.planner.iso.transformer.RecursiveGraphTransformer.transform(RecursiveGraphTransformer.java:118)
      3. cascading.flow.planner.iso.transformer.RecursiveGraphTransformer.transform(RecursiveGraphTransformer.java:72)
      4. cascading.flow.planner.rule.RuleTransformer.transform(RuleTransformer.java:85)
      5. cascading.flow.planner.rule.RuleExec.performTransform(RuleExec.java:414)
      6. cascading.flow.planner.rule.RuleExec.performMutation(RuleExec.java:224)
      7. cascading.flow.planner.rule.RuleExec.executeRulePhase(RuleExec.java:176)
      8. cascading.flow.planner.rule.RuleExec.planPhases(RuleExec.java:123)
      9. cascading.flow.planner.rule.RuleExec.exec(RuleExec.java:84)
      10. cascading.flow.planner.rule.RuleSetExec.execPlannerFor(RuleSetExec.java:153)
      11. cascading.flow.planner.rule.RuleSetExec$3.call(RuleSetExec.java:336)
      12. cascading.flow.planner.rule.RuleSetExec$3.call(RuleSetExec.java:328)
      12 frames
    3. Java RT
      Thread.run
      1. java.util.concurrent.FutureTask.run(FutureTask.java:266)
      2. java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
      3. java.util.concurrent.FutureTask.run(FutureTask.java:266)
      4. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
      5. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
      6. java.lang.Thread.run(Thread.java:745)
      6 frames