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

[ WARN ] javax.management.InstanceAlreadyExistsException

    XMLWordPrintableJSON

Details

    Description

      When Create 2 Kafka Tables with same group.id

       

      CREATE TABLE table1 (
         ...
      ) WITH ( 'connector' = 'kafka',
         'properties.group.id' = 'test-demo',
          ...
      );
      CREATE TABLE table2 (
         ...
      ) WITH ( 'connector' = 'kafka',
         'properties.group.id' = 'test-demo',
          ...
      )
      

       

      We will see warning

      [WARN ] 2021-10-28 00:00:39.013 [SourceCoordinator-Source: KafkaSource-default_catalog.default_database.faceInput1] o.a.f.k.s.o.a.k.c.u.AppInfoParser-[registerAppInfo] - 68 - Error registering AppInfo mbean
      javax.management.InstanceAlreadyExistsException: kafka.admin.client:type=app-info,id=face-integration-group-enumerator-admin-client
       at java.management/com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:436)
       at java.management/com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1855)
       at java.management/com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:955)
       at java.management/com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:890)
       at java.management/com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:320)
       at java.management/com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
       at org.apache.flink.kafka.shaded.org.apache.kafka.common.utils.AppInfoParser.registerAppInfo(AppInfoParser.java:64)
       at org.apache.flink.kafka.shaded.org.apache.kafka.clients.admin.KafkaAdminClient.<init>(KafkaAdminClient.java:500)
       at org.apache.flink.kafka.shaded.org.apache.kafka.clients.admin.KafkaAdminClient.createInternal(KafkaAdminClient.java:444)
       at org.apache.flink.kafka.shaded.org.apache.kafka.clients.admin.Admin.create(Admin.java:59)
       at org.apache.flink.kafka.shaded.org.apache.kafka.clients.admin.AdminClient.create(AdminClient.java:39)
       at org.apache.flink.connector.kafka.source.enumerator.KafkaSourceEnumerator.getKafkaAdminClient(KafkaSourceEnumerator.java:432)
       at org.apache.flink.connector.kafka.source.enumerator.KafkaSourceEnumerator.start(KafkaSourceEnumerator.java:151)
       at org.apache.flink.runtime.source.coordinator.SourceCoordinator.lambda$start$0(SourceCoordinator.java:140)
       at org.apache.flink.runtime.source.coordinator.SourceCoordinator.lambda$runInEventLoop$8(SourceCoordinator.java:331)
       at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
       at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
       at java.base/java.lang.Thread.run(Thread.java:834)

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              wangqinghuan qinghuan wang
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated: