Before we dive further into this can you please explain the jarURI problem your are trying to solve by switching to standalone?
The native mode should work well in almost any setup. Gyula On Thu, 13 Oct 2022 at 21:41, Javier Vegas <jve...@strava.com> wrote: > Hi, I have a S3 HA Flink app that works as expected deployed via > operator 1.2 in native mode, but I am seeing errors when switching to > standalone mode (which I want to do mostly to save me having to set jarURI > explicitly). > I can see the job manager writes the JobGraph in S3, and in the web UI I > can see it creates the jobs, but the taskmanager sits there doing nothing > as if could not communicate with the jobmanager. I can see also that the > operator has created two services, while native mode creates only the rest > service. After a while, the taskmanager closes with the following exception: > > org.apache.flink.runtime.taskexecutor.exceptions.RegistrationTimeoutException: > Could not register at the ResourceManager within the specified maximum > registration duration 300000 ms. This indicates a problem with this > instance. Terminating now. > > at > org.apache.flink.runtime.taskexecutor.TaskExecutor.registrationTimeout(TaskExecutor.java:1474) > > at > org.apache.flink.runtime.taskexecutor.TaskExecutor.lambda$startRegistrationTimeout$16(TaskExecutor.java:1459) > > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRunAsync$4(AkkaRpcActor.java:443) > > at > org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) > > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:443) > > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:213) > > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) > > at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) > > at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) > > at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) > > at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) > > at > akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) > > at > scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) > > at > scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) > > at > scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) > > at akka.actor.Actor.aroundReceive(Actor.scala:537) > > at akka.actor.Actor.aroundReceive$(Actor.scala:535) > > at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) > > at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) > > at akka.actor.ActorCell.invoke(ActorCell.scala:548) > > at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) > > at akka.dispatch.Mailbox.run(Mailbox.scala:231) > > at akka.dispatch.Mailbox.exec(Mailbox.scala:243) > > at java.base/java.util.concurrent.ForkJoinTask.doExec(Unknown > Source) > > at > java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(Unknown > Source) > > at java.base/java.util.concurrent.ForkJoinPool.scan(Unknown > Source) > > at java.base/java.util.concurrent.ForkJoinPool.runWorker(Unknown > Source) > at > java.base/java.util.concurrent.ForkJoinWorkerThread.run(Unknown Source) > >
