crunch-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jinal Shah <>
Subject Pipeline throwing No Output? exception
Date Sat, 15 Mar 2014 19:34:44 GMT

I actually came across a particular case I'm not sure whether the behavior
is right or not. So here is what is happening I am getting No Output
exception throwing while trying to run my Crunch job. On further
investigating I found that I was using Pipeline.emptyCollection(). So here
is how my scenario looks like

PCollection<V> collectionWhichCouldBeEmpty = null;
    collectionWhichCouldBeEmpty=, PType.V);
} else{
    collectionWhichCouldBeEmpty = pipeline.emptyPCollection();

//do some operations

pipeline.write(Target); this is where it is throwing the error

On further debugging I found that the Vertex didn't have an input.

So If I use the and it creates an Empty PCollection it works
since it has the input source but If I create an Empty PCollection using
the pipeline.emptyPCollection which doesn't have an input source then it

Not sure if the case is missed or it has to be like this.


  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message