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

lient-timeout Regards, Roman On Thu, Jun 10, 2021 at 6:34 AM 陳樺威 wrote: > > 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&#

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

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

akka.pattern.AskTimeoutException: Ask timed out (after upgrading to flink 1.4.0)

ad.run(Thread.java:748) Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka.tcp://flink@flink-1682409794-3n335:42536/user/taskmanager#262833087]] after [1 ms]. Sender[null] sent message of type "org.apache.flink.runtime.messages.JobManagerMessages$LeaderSessionMessage&q

Re: akka.pattern.AskTimeoutException

Hi Stefano, In my case running the program in a machine with more ram solved the problem. Have you tried enabling debugging as Till's suggested? Fred On Wed, Mar 16, 2016 at 1:51 PM, stefanobaghino < stefano.bagh...@radicalbit.io> wrote: > Frederick, > > did you find the problem? I'm having a s

Re: akka.pattern.AskTimeoutException

Hi Frederick, thanks for helping me, in the end it looked like it was just a missing property in the ones I gave to Kafka, but the error message looks really misleading. Thanks again. Best, Stefano On Wed, Mar 16, 2016 at 4:04 PM, Frederick Ayala wrote: > Hi Stefano, > > In my case running the

Re: akka.pattern.AskTimeoutException

Frederick, did you find the problem? I'm having a similar issue (the timeout apparently goes off immediately, despite the error message) with a very simple test job that reads from Kafka, appends a string to the input and writes it back to Kafka. Other jobs seem to work fine as well. -- View th

Re: akka.pattern.AskTimeoutException

se. >>>> >>>> I have no idea what the problem could be. >>>> Has the exception been thrown from the env.execute() call? >>>> Why did you set the akka.ask.timeout to 10k seconds? >>>> >>>> >>>> >>>> >

Re: akka.pattern.AskTimeoutException

gt;> >>> >>> On Wed, Jan 13, 2016 at 2:13 AM, Frederick Ayala < >>> frederickay...@gmail.com> wrote: >>> >>>> Hi, >>>> >>>> I am having an error while running some Flink transformations in a >>>> Data

Re: akka.pattern.AskTimeoutException

;> >> >> >> On Wed, Jan 13, 2016 at 2:13 AM, Frederick Ayala < >> frederickay...@gmail.com> wrote: >> >>> Hi, >>> >>> I am having an error while running some Flink transformations in a >>> DataStream Scala API. >>&

Re: akka.pattern.AskTimeoutException

;> >> I am having an error while running some Flink transformations in a >> DataStream Scala API. >> >> The error I get is: >> >> Timeout while waiting for JobManager answer. Job time exceeded 21474835 >> seconds >> ... >> >> Caused by: a

Re: akka.pattern.AskTimeoutException

an error while running some Flink transformations in a > DataStream Scala API. > > The error I get is: > > Timeout while waiting for JobManager answer. Job time exceeded 21474835 > seconds > ... > > Caused by: akka.pattern.AskTimeoutException: Ask timed out on > [Actor

akka.pattern.AskTimeoutException

Hi, I am having an error while running some Flink transformations in a DataStream Scala API. The error I get is: Timeout while waiting for JobManager answer. Job time exceeded 21474835 seconds ... Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/$a