Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-34429

Adding K8S Annotations to Internal Service

    XMLWordPrintableJSON

Details

    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

          Web Link GitHub Pull Request #24348

          Activity

            People

              barakbn@gmail.com Barak Ben-Nathan
              barakbn@gmail.com Barak Ben-Nathan
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: