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)
