Github user ChengzhiZhao commented on the issue: https://github.com/apache/flink/pull/5521 @StephanEwen, thanks for your feedbacks. for our use case we'd like to take the bad file out to continue process instead of fixing the bad file to be able to continue. I think it can be more as job/application specific so we won't have it globally, it will give people flexibility. If that is the decision here, we can do as a connector parameter not via config which affect all the jobs. Please suggest.