Uploaded image for project: 'Apache Apex Malhar'
  1. Apache Apex Malhar
  2. APEXMALHAR-1637

Cleanup skipping of records from setup of FSDirectoryInputOperator

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • 2.1.0
    • adapters other
    • 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.

      Attachments

        Activity

          People

            csingh Chandni Singh
            csingh Chandni Singh
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: