Class JMXService


  • public class JMXService
    extends Object
    Provide a JVM-wide singleton JMX Service.
    • Constructor Detail

      • JMXService

        public JMXService()
    • Method Detail

      • getInstance

        public static Optional<org.apache.flink.management.jmx.JMXServer> getInstance()
        Acquire the global singleton JMXServer instance.
      • startInstance

        public static void startInstance​(String portsConfig)
        Start the JMV-wide singleton JMX server.

        If JMXServer static instance is already started, it will not be started again. Instead a warning will be logged indicating which port the existing JMXServer static instance is exposing.

        Parameters:
        portsConfig - port configuration of the JMX server.
      • stopInstance

        public static void stopInstance()
                                 throws IOException
        Stop the JMX server.
        Throws:
        IOException