What is the correct behavior for an operator when it receives an IterOutcome.STOP from upstream: 1. should it just stop right away and return STOP downstream ?, or 2. should it cleanup it's resources before returning STOP downstream ?
Some operators follow 1 and others (like OrderedPartitionRecordBatch) follow 2. -- Abdelhakim Deneche Software Engineer <http://www.mapr.com/> Now Available - Free Hadoop On-Demand Training <http://www.mapr.com/training?utm_source=Email&utm_medium=Signature&utm_campaign=Free%20available>