search

NICTA / scoobi

A Scala productivity framework for Hadoop.
http://nicta.github.com/scoobi/
482 stars 97 forks source link

Scoobi crashes with input channel not found #215

Closed espringe closed 11 years ago

espringe commented 11 years ago

To reproduce:

    // start off by creating a dummy file
    persist((1 to 100).toDList.map { x => x.toString -> x.toString }.toAvroFile("blah", true))

    // ok, now try read and use it
    val input = fromAvroFile[(String, String)]("blah")
    val finalResult = input.materialise join input.groupByKey
    persist(finalResult)
etorreborre commented 11 years ago

I should hire you as a tester...

espringe commented 11 years ago

..pffft. B. Franklin said it best: "He who sacrifices freedom of footware for a better job deserves neither."