If we understand your issue very well, some of your input files contain invalid data which cause job to break? What's kind of invalid data? Is it a schema mismatch? If that is the case you can use a tSchemaComplianceCheck to ensure incoming data matches a required schema, length, nullability, etc.
