Hi Everybody, I am complete newbie to using parkour. I am having trouble just reading in data. Can somebody help me figure out the problem.
The code I am using is here.. https://gist.github.com/52f4298e5b6ca6a46699 I agree that there is no other stage apart from the input. I had all other stages but removed them to zero-in on the problem to create the smallest possible code to reproduce the problem. I am running the uber-jar with the following command hadoop jar mr.jar It is able to list the files which have been specified with a wild-card so it seems like it is able to talk to the hdfs. I am a complete noob to parkour .. so please excuse any stupid mistakes and explain the same. Thanks, Sunil. The error I get is here #<DSeq conf={"mapreduce.job.inputformat.class" "org.apache.hadoop.mapreduce.lib.input.TextInputFormat", "mapreduce.input.fileinputformat.inputdir" "hdfs:// hadoopcl2slave1.bidstalk.com:8020/user/hdfs/rawlogs/2015022006/2015022006-chi-event1-notify-acc.log,hdfs://hadoopcl2slave1.bidstalk.com:8020/user/hdfs/rawlogs/2015022006/2015022006-chi-event2-notify-acc.log,hdfs://hadoopcl2slave1.bidstalk.com:8020/user/hdfs/rawlogs/2015022006/2015022006-chi-event3-notify-acc.log,hdfs://hadoopcl2slave1.bidstalk.com:8020/user/hdfs/rawlogs/2015022006/2015022006-chi-event4-notify-acc.log,hdfs://hadoopcl2slave1.bidstalk.com:8020/user/hdfs/rawlogs/2015022006/2015022006-chi-event6-notify-acc.log", "parkour.source-as.default" ":vals"}> 15/02/22 12:22:26 ERROR parkour.tool: Uncaught exception: java.lang.IllegalArgumentException: Don't know how to create ISeq from: clojure.core.reducers$folder$reify__5580 java.lang.IllegalArgumentException: Don't know how to create ISeq from: clojure.core.reducers$folder$reify__5580 at clojure.lang.RT.seqFrom(RT.java:506) at clojure.lang.RT.seq(RT.java:487) at clojure.core$seq__7216.invoke(core.clj:135) at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) at clojure.core.protocols$eval10183$fn__10184.invoke(protocols.clj:42) at clojure.core.protocols$eval10104$fn__10105$G__10095__10118.invoke(protocols.clj:13) at clojure.core$reduce.invoke(core.clj:6514) at clojure.core$into.invoke(core.clj:6595) at parkour.graph$execute.invoke(graph.clj:458) at impressions.core$counter_tool.invoke(core.clj:14) at impressions.core$tool.invoke(core.clj:21) at clojure.lang.AFn.applyToHelper(AFn.java:156) at clojure.lang.AFn.applyTo(AFn.java:144) at clojure.core$apply.invoke(core.clj:628) at parkour.tool.ParkourTool$fn__13080.invoke(tool.clj:33) at parkour.tool$integral_STAR_.invoke(tool.clj:12) at parkour.tool.ParkourTool.run(tool.clj:31) at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:70) at parkour.tool$run.invoke(tool.clj:50) at parkour.tool$run.invoke(tool.clj:45) at impressions.core$_main.doInvoke(core.clj:25) at clojure.lang.RestFn.invoke(RestFn.java:397) at clojure.lang.AFn.applyToHelper(AFn.java:152) at clojure.lang.RestFn.applyTo(RestFn.java:132) at impressions.core.main(Unknown Source) 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.main(RunJar.java:212) -- You received this message because you are subscribed to the Google Groups "Clojure" group. To post to this group, send email to clojure@googlegroups.com Note that posts from new members are moderated - please be patient with your first post. To unsubscribe from this group, send email to clojure+unsubscr...@googlegroups.com For more options, visit this group at http://groups.google.com/group/clojure?hl=en --- You received this message because you are subscribed to the Google Groups "Clojure" group. To unsubscribe from this group and stop receiving emails from it, send an email to clojure+unsubscr...@googlegroups.com. For more options, visit https://groups.google.com/d/optout.
