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

Discussion Posts

Follow ups

Related Discussions

Discussion Navigation
viewthread | post
posts ‹ prev | 1 of 5 | next ›
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