[
https://issues.apache.org/jira/browse/FLINK-34429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-34429.
-----------------------------------
Resolution: Done
> 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
> Assignee: Barak Ben-Nathan
> Priority: Minor
> Labels: pull-request-available
> Fix For: 1.20.0
>
>
> 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)
