pnowojski commented on a change in pull request #9221:
[FLINK-13376][datastream] ContinuousFileReaderOperator should respect…
URL: https://github.com/apache/flink/pull/9221#discussion_r308697279
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functio
pnowojski commented on a change in pull request #9221:
[FLINK-13376][datastream] ContinuousFileReaderOperator should respect…
URL: https://github.com/apache/flink/pull/9221#discussion_r308690531
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functio
pnowojski commented on a change in pull request #9221:
[FLINK-13376][datastream] ContinuousFileReaderOperator should respect…
URL: https://github.com/apache/flink/pull/9221#discussion_r308567382
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functio
pnowojski commented on a change in pull request #9221:
[FLINK-13376][datastream] ContinuousFileReaderOperator should respect…
URL: https://github.com/apache/flink/pull/9221#discussion_r308570824
##
File path:
flink-tests/src/test/java/org/apache/flink/test/streaming/api/ContinuousF
pnowojski commented on a change in pull request #9221:
[FLINK-13376][datastream] ContinuousFileReaderOperator should respect…
URL: https://github.com/apache/flink/pull/9221#discussion_r308568245
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functio
pnowojski commented on a change in pull request #9221:
[FLINK-13376][datastream] ContinuousFileReaderOperator should respect…
URL: https://github.com/apache/flink/pull/9221#discussion_r308568937
##
File path:
flink-tests/src/test/java/org/apache/flink/test/streaming/api/ContinuousF
pnowojski commented on a change in pull request #9221:
[FLINK-13376][datastream] ContinuousFileReaderOperator should respect…
URL: https://github.com/apache/flink/pull/9221#discussion_r308570690
##
File path:
flink-tests/src/test/java/org/apache/flink/test/streaming/api/ContinuousF