Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Done
-
None
Description
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:
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]
To avoid these we need to add special Annotations to the internal service.
Attachments
Issue Links
- links to