[GitHub] [flink] pnowojski commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect…

2019-07-30 Thread GitBox
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

[GitHub] [flink] pnowojski commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect…

2019-07-30 Thread GitBox
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

[GitHub] [flink] pnowojski commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect…

2019-07-30 Thread GitBox
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

[GitHub] [flink] pnowojski commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect…

2019-07-30 Thread GitBox
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

[GitHub] [flink] pnowojski commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect…

2019-07-30 Thread GitBox
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

[GitHub] [flink] pnowojski commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect…

2019-07-30 Thread GitBox
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

[GitHub] [flink] pnowojski commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect…

2019-07-30 Thread GitBox
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