ongLee"< lzljs3620...@aliyun.com.INVALID ;
>
> 发件时间：2020/3/4 17:40
>
> 收件人："user-zh"< user-zh@flink.apache.org ;
>
> 主题： Re: flink 1.8 内的StreamExecutionEnvironment 对于 FileInputFormat 多file
> path 不兼容问题咨询
>
>
>
> Hi, 你的需求是什么？下列哪种？ - 1.想用unbounded s
eamExecutionEnvironment 对于 FileInputFormat 多file path
不兼容问题咨询
Hi, 你的需求是什么？下列哪种？ - 1.想用unbounded source，continuous的file
source，监控文件夹，发送新文件，且需要支持多文件夹 - 2.只是想用bounded的input format，需要支持多文件 如果是1，现在仍然不支持。
如果是2，那你可以用env.addSource(new InputFormatSourceFunction(..)...)来
Hi,
你的需求是什么？下列哪种？
- 1.想用unbounded source，continuous的file source，监控文件夹，发送新文件，且需要支持多文件夹
- 2.只是想用bounded的input format，需要支持多文件
如果是1，现在仍然不支持。
如果是2，那你可以用env.addSource(new InputFormatSourceFunction(..)...)来支持多文件。
Best,
Jingsong Lee
--
