Re: AskTimeoutException

2019-04-24 Thread Alex Soto
olution is to upgrade to 1.7.3 or 1.8.0 Best regards, Alex soto > On Apr 24, 2019, at 1:39 PM, Alex Soto wrote: > > Thanks Abdul for the help. So I added this: > > cfg.setString(AkkaOptions.LOOKUP_TIMEOUT, "2 min"); > > > But I am still

Re: AskTimeoutException

2019-04-24 Thread Alex Soto
-199361569]] after [1 ms]. Sender[null] sent message of type "org.apache.flink.runtime.rpc.messages.LocalFencedMessage". Best regards, Alex soto > On Apr 12, 2019, at 6:34 PM, Abdul Qadeer wrote: > > Hi Alex, > > The timeout shown in the exception is due to

AskTimeoutException

2019-04-12 Thread Alex Soto
creating the local environment. I am passing 2 minutes, bu the error message says it timed out after 10 seconds. Best regards, Alex soto

akka.remote.OversizedPayloadException

2018-04-23 Thread Alex Soto
with the command line client: flink run -m … No matter what I do, I always get the same error message with the same default limit. Please help, I am not finding any information on how to override the default limit. Best regards, Alex soto