Hi,

I'm configuring a Flink cluster with high availability based on ZooKeeper
and two Job Managers.

When I upload a jar using the /jars/upload REST API, I don't get the jar
replicated in both JMs. Is this the expected behavior?

I want to configure the cluster in such a way that once the jar is
uploaded, I'm able to schedule multiple jobs based on the same jar id,
independently of what is the leader JM at the scheduling time.

Also, I'm using a K8 service to reach the job managers, this service choose
one of the JM pods in every request, should I invoke always the leader one?

Thanks

Reply via email to