Hi.

When pipeline fails on cluster with some exception, materialize() returns
empty collection and just logs error message.

I'm (very, very) puzzled about this behaviour:
https://github.com/apache/crunch/blob/master/crunch-core/src/main/java/org/apache/crunch/materialize/MaterializableIterable.java#L92
Is this really intended behaviour?

If so, then some documentation for materialize() function about this
behaviour would be really nice to have. :)


--
Mārtiņš

Reply via email to