You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Danny Cranmer (Jira)" <ji...@apache.org> on 2024/02/13 09:31:00 UTC
[jira] [Commented] (FLINK-34429) Adding K8S Annotations to Internal Service
[ https://issues.apache.org/jira/browse/FLINK-34429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816929#comment-17816929 ]
Danny Cranmer commented on FLINK-34429:
---------------------------------------
Thanks for raising [~barakbn@gmail.com] , assigning to you.
> 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
>
> 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)