Re: Should flink job manager crash during zookeeper upgrade?

Thank you Till, that's perfect. I increased the max retry attempts a bit, and now it works like a charm ( no restarts ). -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Should flink job manager crash during zookeeper upgrade?

Great, thank you for help Matthias -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Should flink job manager crash during zookeeper upgrade?

I'm trying to understand if behaviour of the flink jobmanager during zookeeper upgrade is expected or not. I'm running flink 1.11.2 in kubernetes, with zookeeper server 3.5.4-beta. While I'm doing zookeeper upgrade, there is a 20 seconds zookeeper downtime. I'd expect to either flink job to restar

Re: can taskmanager listen on all interfaces, like jobmanager?

Great, thank you very much :) -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

can taskmanager listen on all interfaces, like jobmanager?

I've notice that jobmanager ports all listen on all interfaces by default, as well as data port on the taskmanager. The only exception is the taskmanager RPC port, ``` bash-4.2$ netstat -lpn | grep 612 tcp0 0 172.20.54.176:6121 0.0.0.0:* LISTEN 54/java tcp

Re: is it possible to upgrade zookeeper without having job managers restart

Great, thank you :) -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

is it possible to upgrade zookeeper without having job managers restart

We are running flink 1.10 cluster, with 3 zookeepers for HA. I noticed that trying to upgrade the zookeepers, even 1 by one, causes jobmanagers to crash ``` java.net.UnknownHostException: foo-host: Name or service not known at java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method)

Does it make sense to use init containers for job upgrades in kubernetes

Hi, we are attempting to migrate our flink cluster to K8, and are looking into options how to automate job upgrades; wondering if anyone here has done it with init container? Or if there is a simpler way? 0: So, let's assume we have a job manager with few task managers running, in a stateful set;

Either bug in the flink, or out of date documentation ( flink 1.6 , cancel API rest endpoint )

In the flink documenation, to cancel the job, request should be made to DELETE request to /jobs/:jobid/cancel https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/rest_api.html#job-cancellation However, when I run this command, I get 404 back from the jobmanager. After reading the s

Re: Wondering how to check if taskmanager is registered with the jobmanager, without asking job manager

Version of flink I'm using is 1.6.1, if that helps. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/