Barak Ben-Nathan created FLINK-34429: ----------------------------------------
Summary: Adding K8S Annotations to Internal Service Key: FLINK-34429 URL: https://issues.apache.org/jira/browse/FLINK-34429 Project: Flink Issue Type: Improvement Components: Deployment / Kubernetes Reporter: Barak Ben-Nathan Flink currently supports adding Annotations to the Rest Service (with the configuration key: kubernetes.rest-service.annotations). New configuration key: kubernetes.internal-service.annotations should be added to allow the same functionality for the internal service. This is useful, for example, when implementing Teleport app discovery. Without special annotation to the service, Teleport floods the JobManger with errors: {code:java} 2024-02-12 09:24:43,747 WARN org.apache.pekko.remote.transport.netty.NettyTransport [] - Remote connection to [/172.16.108.253:39884] failed with org.jboss.netty.handler.codec.frame.TooLongFrameException: Adjusted frame length exceeds 10485760: 369295621 - discarded 2024-02-12 09:24:43,753 ERROR org.apache.flink.runtime.blob.BlobServerConnection [] - Error while executing BLOB connection from /172.16.108.253:40954. java.io.IOException: Unknown operation 22 at org.apache.flink.runtime.blob.BlobServerConnection.run(BlobServerConnection.java:116) [flink-dist-1.18.1.jar:1.18.1] {code} To avoid these we need to add [special Annotations|https://github.com/gravitational/teleport/blob/master/rfd/0135-kube-apps-discovery.md#annotations] to the internal service. -- This message was sent by Atlassian Jira (v8.20.10#820010)