Re: FileSource may cause akka.pattern.AskTimeoutException, and akka.ask.timeout not workable

2021-06-10 Thread Roman Khachatryan
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

FileSource may cause akka.pattern.AskTimeoutException, and akka.ask.timeout not workable

2021-06-09 Thread 陳樺威
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