Hi,
I think you need to increase client.timeout [1].
Regarding the FileSource, it's difficult to say whether it is the
reason. The logs you provided are from the client, JobManager logs
would be helpful.
[1]
https://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/config/#client-tim
Hello all,
Our team encounter *akka.pattern.AskTimeoutException *when start
jobmanager. Base on the error message, we try to setup *akka.ask.timeout *
and* web.timeout *to 360s, but both of them doesn't work.
We guess the issue may cause by *FileSource.forRecordFileFormat.* The
application will l