count breaks my queries

[Oskar]

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?

[Andy Xue]

i think you are missing a :> ?

[Oskar]

In this tutorial it is used like that (without :>) http://nathanmarz.com/blog/introducing-cascalog-a-clojure-based-query-language-for-hado.html

[Paul Lam]

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?

[Oskar]

Yeah, it was a problem with my hadoop install.