FLink

java.util.concurrent.TimeoutException: Invocation of [RemoteRpcInvocation(TaskExecutorGateway.requestSlot(SlotID, JobID, AllocationID, ResourceProfile, String, ResourceManagerId, Time))] at recipient [akka.tcp://flink@test
e-34:40647/user/rpc/taskmanager_0] timed out. This is usually caused by: 1) Akka failed sending the message silently, due to problems like oversized payload or serialization failures. In that case, you should find detailed error informa
tion in the logs. 2) The recipient needs more time for responding, due to problems like slow machines or network jitters. In that case, you can try to increase akka.ask.timeout.
    at org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager.allocateSlot(DeclarativeSlotManager.java:573) ~[netflow-jar-with-dependencies.jar:?]
    at org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager.internalTryAllocateSlots(DeclarativeSlotManager.java:523) ~[netflow-jar-with-dependencies.jar:?]
    at org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager.tryAllocateSlotsForJob(DeclarativeSlotManager.java:489) ~[netflow-jar-with-dependencies.jar:?]
    at org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager.checkResourceRequirements(DeclarativeSlotManager.java:456) ~[netflow-jar-with-dependencies.jar:?]
    at org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager.registerTaskManager(DeclarativeSlotManager.java:344) ~[netflow-jar-with-dependencies.jar:?]
    at org.apache.flink.runtime.resourcemanager.ResourceManager.sendSlotReport(ResourceManager.java:461) ~[netflow-jar-with-dependencies.jar:?]
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_212]
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_212]
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_212]
    at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_212]
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:304) ~[flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) ~[flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:302) ~[flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) ~[flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) ~[flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) ~[flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) [flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) [flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) [flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) [flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) [flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) [flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at akka.actor.Actor.aroundReceive(Actor.scala:537) [flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at akka.actor.Actor.aroundReceive$(Actor.scala:535) [flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) [flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) [flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at akka.actor.ActorCell.invoke(ActorCell.scala:548) [flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) [flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at akka.dispatch.Mailbox.run(Mailbox.scala:231) [flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at akka.dispatch.Mailbox.exec(Mailbox.scala:243) [flink-rpc-akka_2667e9e9-25a0-40df-bc49-320b10577842.jar:1.15.1]
    at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) [?:1.8.0_212]
    at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) [?:1.8.0_212]
    at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) [?:1.8.0_212]
    at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157) [?:1.8.0_212]
Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka.tcp://flink@test:40647/user/rpc/taskmanager_0#1491933003]] after [100 ms]. Message of type [org.apache.flink.runtime.rpc.messages.RemoteRpcInvoc
ation]. A typical reason for `AskTimeoutException` is that the recipient actor didn't send a reply.

akka.ask.timeout: 100000
web.timeout: 300000