Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
Description
Currently the FSDirectoryInput operator skip records in setup for unfinished and failed files.
I believe the current file is converted to an Unfinished file in definePartitions.
This logic in setup may not be needed at all as skipping of records is already taken care in emitTuples().
So we should remove it from setup(...) and make it sure it doesn't break anything.