Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5521#discussion_r173453379 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java --- @@ -340,6 +341,10 @@ public void run() { } } + } catch (FileNotFoundException e) { + if (LOG.isDebugEnabled()) { --- End diff -- This needs to be more prominently logged than `debug`. Should be at least `info` or `warn`. Please also use the placeholder syntax from log4j, to make the code simpler.
---