How to know if Job nodes are registered in cluster?

Hi running flink 1.10 I have 3 zookeeper nodes and 3 job nodes. 1 nodes has specifically indicated that it was granted leadership with token. The other 2 job nodes. Indicate: Starting ZooKeeperLeaderElectionService ZooKeeperLeaderElectionService{leaderPath='/leader/resource_manager_lock'}. So is

RE: Suspected SPAM - RE: CVE-2021-44228 - Log4j2 vulnerability

Hi, We are using hadoop2 uber jar provided by flink. As there are many CVE’s being reported for logging, any CVE’s appliable to this uber jar? https://repo.maven.apache.org/maven2/org/apache/flink/flink-shaded-hadoop-2-uber/2.7.5-10.0/flink-shaded-hadoop-2-uber-2.7.5-10.0.jar Thanks, Suchithra

RE: CVE-2021-44228 - Log4j2 vulnerability

Hi, It seems there is high severity vulnerability in log4j 2.16.0.(CVE-2021-45105) Refer : https://logging.apache.org/log4j/2.x/security.html Any update on this please? Regards, Suchithra From: Chesnay Schepler Sent: Thursday, Dece

org.apache.flink.connector.jdbc.internal.JdbcBatchingOutputFormat class missing from Flink 1.14 ?

I am just trying out Flink using images from Docker Hub. My simple insert using JDBC connector to Postgres database fails with this error Flink SQL> insert into order_counts > select customerid, count(*) order_count from orders group by customerid; [INFO] Submitting SQL update statement to the cl