支持多文件。 Best,
Jingsong Lee ------
From:王智Send Time:2020年3月4日(星期三) 17:34 To:user-zhSubject:flink 1.8
内的StreamExecutionEnvironment 对于 FileInputFormat 多file path 不兼容问题咨询 我在使用flink
1.8 自定义 FileInputFormat
的时候遇到了不兼容问题，初步看了源代码，不知道自己得出的结论是否正确，并想了解一下后续趋势和
我在使用flink 1.8 自定义 FileInputFormat
的时候遇到了不兼容问题，初步看了源代码，不知道自己得出的结论是否正确，并想了解一下后续趋势和进展，麻烦各位大佬抽空指点一下，先行感谢~~
问题1: StreamExecutionEnvironment 为什么要做这样的限制？ContinuousFileMonitoringFunction
的作用是什么？
相关的代码描述如下
StreamExecutionEnvironment 对 FileInputFormat 对象有特殊的处理逻辑
if (inputFormat instanceof
感谢大神，
是我配置的资源太少导致响应慢，导致akka 超时。
现在我换了一个k8s 集群，调大了资源，已经不再配到邮件中的发生的异常。
原始邮件
发件人："Zili Chen"< wander4...@gmail.com ;
发件时间：2019/8/7 15:32
收件人："王智"< ben.wa...@foxmail.com ;
抄送人："user-zh"< user-zh@flink.apache.org ;
主题：Re: Re: submit jobGraph e
spatcher 的时候 akka ask timeout
了，可以检查一下配置的地址和端口是否正确，或者贴出你的相关配置。
Best,
tison.
王智于2019年8月6日周二 下午7:13写道：
向session cluster 提交job 出错，麻烦各位老师帮忙看下，给点排查提示 THX~
环境:
blink 1.8.0
用docker 方式启动的flink session cluster，flink 集群独立，我从集群外的一个docker
节点提交job（该节点的flink-conf.yaml 配置与flink 集群内的配置一致）
向session cluster 提交job 出错，麻烦各位老师帮忙看下，给点排查提示 THX~
环境:
blink 1.8.0
用docker 方式启动的flink session cluster，flink 集群独立，我从集群外的一个docker
节点提交job（该节点的flink-conf.yaml 配置与flink 集群内的配置一致）
--
报错信息:
The program finished
