Hi!

I have some data that are 2-tuples. This query works:

(?<- (stdout) [?user ?events] (data ?user ?events)) ;WORKS

But these:

(?<- (stdout) [?count] (data ?user ?events) (c/count ?count)) ;NOT WORKING
(?<- (stdout) [?count] (data _ _) (c/count ?count)) ;NOT WORKING

cause this:

cascading.flow.FlowException: local step failed
at cascading.flow.planner.FlowStepJob.blockOnJob (FlowStepJob.java:191)
cascading.flow.planner.FlowStepJob.start (FlowStepJob.java:137)
cascading.flow.planner.FlowStepJob.call (FlowStepJob.java:122)
cascading.flow.planner.FlowStepJob.call (FlowStepJob.java:42)
java.util.concurrent.FutureTask$Sync.innerRun (:-1)
java.util.concurrent.FutureTask.run (:-1)
java.util.concurrent.ThreadPoolExecutor.runWorker (:-1)
java.util.concurrent.ThreadPoolExecutor$Worker.run (:-1)
java.lang.Thread.run (:-1)


My namespace, if that matters:

(ns querytest
(:require [cascalog.ops :as c])
(:use cascalog.api
[cascalog.io :only [with-log-level]]))

What's going on?

Search Discussions

  • Andy Xue at Nov 28, 2012 at 4:58 pm
    i think you are missing a :> ?
    On Wednesday, November 28, 2012 2:54:59 AM UTC-5, Oskar wrote:

    Hi!

    I have some data that are 2-tuples. This query works:

    (?<- (stdout) [?user ?events] (data ?user ?events)) ;WORKS

    But these:

    (?<- (stdout) [?count] (data ?user ?events) (c/count ?count)) ;NOT WORKING
    (?<- (stdout) [?count] (data _ _) (c/count ?count)) ;NOT WORKING

    cause this:

    cascading.flow.FlowException: local step failed
    at cascading.flow.planner.FlowStepJob.blockOnJob (FlowStepJob.java:191)
    cascading.flow.planner.FlowStepJob.start (FlowStepJob.java:137)
    cascading.flow.planner.FlowStepJob.call (FlowStepJob.java:122)
    cascading.flow.planner.FlowStepJob.call (FlowStepJob.java:42)
    java.util.concurrent.FutureTask$Sync.innerRun (:-1)
    java.util.concurrent.FutureTask.run (:-1)
    java.util.concurrent.ThreadPoolExecutor.runWorker (:-1)
    java.util.concurrent.ThreadPoolExecutor$Worker.run (:-1)
    java.lang.Thread.run (:-1)


    My namespace, if that matters:

    (ns querytest
    (:require [cascalog.ops :as c])
    (:use cascalog.api
    [cascalog.io :only [with-log-level]]))

    What's going on?


  • Oskar at Nov 28, 2012 at 5:23 pm
    In this tutorial it is used like that (without :>)
    http://nathanmarz.com/blog/introducing-cascalog-a-clojure-based-query-language-for-hado.html
    On Wednesday, November 28, 2012 5:58:46 PM UTC+1, Andy Xue wrote:

    i think you are missing a :> ?
    On Wednesday, November 28, 2012 2:54:59 AM UTC-5, Oskar wrote:

    Hi!

    I have some data that are 2-tuples. This query works:

    (?<- (stdout) [?user ?events] (data ?user ?events)) ;WORKS

    But these:

    (?<- (stdout) [?count] (data ?user ?events) (c/count ?count)) ;NOT WORKING
    (?<- (stdout) [?count] (data _ _) (c/count ?count)) ;NOT WORKING

    cause this:

    cascading.flow.FlowException: local step failed
    at cascading.flow.planner.FlowStepJob.blockOnJob (FlowStepJob.java:191)
    cascading.flow.planner.FlowStepJob.start (FlowStepJob.java:137)
    cascading.flow.planner.FlowStepJob.call (FlowStepJob.java:122)
    cascading.flow.planner.FlowStepJob.call (FlowStepJob.java:42)
    java.util.concurrent.FutureTask$Sync.innerRun (:-1)
    java.util.concurrent.FutureTask.run (:-1)
    java.util.concurrent.ThreadPoolExecutor.runWorker (:-1)
    java.util.concurrent.ThreadPoolExecutor$Worker.run (:-1)
    java.lang.Thread.run (:-1)


    My namespace, if that matters:

    (ns querytest
    (:require [cascalog.ops :as c])
    (:use cascalog.api
    [cascalog.io :only [with-log-level]]))

    What's going on?


  • Paul Lam at Nov 29, 2012 at 10:06 am
    I tried this in bootstrap and it works: (?<- (stdout) [?count] (age ?person
    ?age) (c/count ?count))

    what's your `data`? is it a sub-query?


    On Wednesday, November 28, 2012 6:16:35 PM UTC+1, Oskar wrote:

    In this tutorial it is used like that (without :>)
    http://nathanmarz.com/blog/introducing-cascalog-a-clojure-based-query-language-for-hado.html
    On Wednesday, November 28, 2012 5:58:46 PM UTC+1, Andy Xue wrote:

    i think you are missing a :> ?
    On Wednesday, November 28, 2012 2:54:59 AM UTC-5, Oskar wrote:

    Hi!

    I have some data that are 2-tuples. This query works:

    (?<- (stdout) [?user ?events] (data ?user ?events)) ;WORKS

    But these:

    (?<- (stdout) [?count] (data ?user ?events) (c/count ?count)) ;NOT
    WORKING
    (?<- (stdout) [?count] (data _ _) (c/count ?count)) ;NOT WORKING

    cause this:

    cascading.flow.FlowException: local step failed
    at cascading.flow.planner.FlowStepJob.blockOnJob (FlowStepJob.java:191)
    cascading.flow.planner.FlowStepJob.start (FlowStepJob.java:137)
    cascading.flow.planner.FlowStepJob.call (FlowStepJob.java:122)
    cascading.flow.planner.FlowStepJob.call (FlowStepJob.java:42)
    java.util.concurrent.FutureTask$Sync.innerRun (:-1)
    java.util.concurrent.FutureTask.run (:-1)
    java.util.concurrent.ThreadPoolExecutor.runWorker (:-1)
    java.util.concurrent.ThreadPoolExecutor$Worker.run (:-1)
    java.lang.Thread.run (:-1)


    My namespace, if that matters:

    (ns querytest
    (:require [cascalog.ops :as c])
    (:use cascalog.api
    [cascalog.io :only [with-log-level]]))

    What's going on?


  • Oskar at Dec 4, 2012 at 3:19 pm
    Yeah, it was a problem with my hadoop install.
    On Thursday, November 29, 2012 11:06:39 AM UTC+1, Paul Lam wrote:

    I tried this in bootstrap and it works: (?<- (stdout) [?count] (age
    ?person ?age) (c/count ?count))

    what's your `data`? is it a sub-query?


    On Wednesday, November 28, 2012 6:16:35 PM UTC+1, Oskar wrote:

    In this tutorial it is used like that (without :>)
    http://nathanmarz.com/blog/introducing-cascalog-a-clojure-based-query-language-for-hado.html
    On Wednesday, November 28, 2012 5:58:46 PM UTC+1, Andy Xue wrote:

    i think you are missing a :> ?
    On Wednesday, November 28, 2012 2:54:59 AM UTC-5, Oskar wrote:

    Hi!

    I have some data that are 2-tuples. This query works:

    (?<- (stdout) [?user ?events] (data ?user ?events)) ;WORKS

    But these:

    (?<- (stdout) [?count] (data ?user ?events) (c/count ?count)) ;NOT
    WORKING
    (?<- (stdout) [?count] (data _ _) (c/count ?count)) ;NOT WORKING

    cause this:

    cascading.flow.FlowException: local step failed
    at cascading.flow.planner.FlowStepJob.blockOnJob (FlowStepJob.java:191)
    cascading.flow.planner.FlowStepJob.start (FlowStepJob.java:137)
    cascading.flow.planner.FlowStepJob.call (FlowStepJob.java:122)
    cascading.flow.planner.FlowStepJob.call (FlowStepJob.java:42)
    java.util.concurrent.FutureTask$Sync.innerRun (:-1)
    java.util.concurrent.FutureTask.run (:-1)
    java.util.concurrent.ThreadPoolExecutor.runWorker (:-1)
    java.util.concurrent.ThreadPoolExecutor$Worker.run (:-1)
    java.lang.Thread.run (:-1)


    My namespace, if that matters:

    (ns querytest
    (:require [cascalog.ops :as c])
    (:use cascalog.api
    [cascalog.io :only [with-log-level]]))

    What's going on?


Related Discussions

Discussion Navigation
viewthread | post
Discussion Overview
groupcascalog-user @
categoriesclojure, hadoop
postedNov 28, '12 at 7:55a
activeDec 4, '12 at 3:19p
posts5
users3
websiteclojure.org
irc#clojure

3 users in discussion

Oskar: 3 posts Andy Xue: 1 post Paul Lam: 1 post

People

Translate

site design / logo © 2021 Grokbase