cascading.flow.planner.PlannerException: in pattern-examples-1.0.0-wip-dev.jar
Opened this issue · 0 comments
I'm trying to run the jar file using
hadoop jar pattern-examples-1.0.0-wip-dev.jar /user/hadoop/iris.glm.xml /user/hadoop/iris.glm.tsv /user/hadoop/part/
but i'm stuck here with this exception
Exception in thread "main" cascading.flow.planner.PlannerException: not all sink taps bound to tail pipes, remaining sink tap names: ['classify']
at cascading.flow.planner.FlowPlanner.verifyPipeAssemblyEndPoints(FlowPlanner.java:312)
at cascading.flow.planner.FlowPlanner.verifyAssembly(FlowPlanner.java:166)
at cascading.flow.hadoop.planner.HadoopPlanner.buildFlow(HadoopPlanner.java:248)
at cascading.flow.hadoop.planner.HadoopPlanner.buildFlow(HadoopPlanner.java:80)
at cascading.flow.FlowConnector.connect(FlowConnector.java:459)
at cascading.pattern.Main.main(Main.java:82)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.apache.hadoop.util.RunJar.run(RunJar.java:221)
at org.apache.hadoop.util.RunJar.main(RunJar.java:136)
I'm using Hadoop version 2.6.0