subject:"\[GitHub\] \[flink\] Jason\-liujc commented on pull request #5415\: \[FLINK\-3655\] \[core\] Support multiple paths in FileInputFormat"

[GitHub] [flink] Jason-liujc commented on pull request #5415: [FLINK-3655] [core] Support multiple paths in FileInputFormat

2021-02-08 Thread GitBox

Jason-liujc commented on pull request #5415: URL: https://github.com/apache/flink/pull/5415#issuecomment-775567716 Yea I basically cloned the source code for `ContinuousFileMonitoringFunction` and added the reading from multiple directories capability to it. I can't really share

[GitHub] [flink] Jason-liujc commented on pull request #5415: [FLINK-3655] [core] Support multiple paths in FileInputFormat

2020-10-09 Thread GitBox

Jason-liujc commented on pull request #5415: URL: https://github.com/apache/flink/pull/5415#issuecomment-705717389 Thanks Fabian! After switching to using `StreamExecutionEnvironment.addSource()`, I encountered this error in Flink 1.8: ```

[GitHub] [flink] Jason-liujc commented on pull request #5415: [FLINK-3655] [core] Support multiple paths in FileInputFormat

2020-10-08 Thread GitBox

Jason-liujc commented on pull request #5415: URL: https://github.com/apache/flink/pull/5415#issuecomment-705717389 Thanks Fabian! After switching to using `StreamExecutionEnvironment.addSource()`, I encountered this error in Flink 1.8: ```

[GitHub] [flink] Jason-liujc commented on pull request #5415: [FLINK-3655] [core] Support multiple paths in FileInputFormat

2020-10-05 Thread GitBox

Jason-liujc commented on pull request #5415: URL: https://github.com/apache/flink/pull/5415#issuecomment-703941810 Question, how do one use this with StreamExecutionEnvironment? It seems in the readFile call, the file path just gets overwritten here: