Hi, Community. There was an issue that happened to one of our Flink Streaming
jobs using 1.14.3 and that job didn't enable JobManager HA. The issue is after
the only jobManager pod's flink-main-container restarted, some of the
taskManager pods keep throwing the below exception:
INFO org.apa
Hello,
I have a stateless Flink job that processes incoming stream as follows:* For a
specific key, an event is produced every 10 sec.* Every 60 sec, the event is
acted upon (the event is modified, enriched). What is important is the event
gets acted upon every 60 second.
* Upon job restart, it
Hi community,
We got this kuerberos error with Hadoop as file system on ECS Fargate
deployment.
Caused by: org.apache.hadoop.security.KerberosAuthException: failure to login:
javax.security.auth.login.LoginException: java.lang.NullPointerException:
invalid null input: name
Caused by: javax.se
