[ https://issues.apache.org/jira/browse/CRUNCH-464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jeremy Beard updated CRUNCH-464: -------------------------------- Attachment: CRUNCH-464.patch Attached patch. > Empty PCollection returns null Long for length().getValue() > ----------------------------------------------------------- > > Key: CRUNCH-464 > URL: https://issues.apache.org/jira/browse/CRUNCH-464 > Project: Crunch > Issue Type: Bug > Components: Core > Affects Versions: 0.10.0 > Reporter: Jeremy Beard > Assignee: Josh Wills > Attachments: CRUNCH-464.patch > > > PCollection lengths are determined by summing 1s for each record, but when > the PCollection is empty there is no sum and so the PObject returns a null > length. Fix is to emit a 0 at the cleanup() of each DoFn instantiation, > forcing a sum when there are no input records. -- This message was sent by Atlassian JIRA (v6.2#6252)