You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/10/28 09:54:00 UTC
[jira] [Updated] (FLINK-24672) [ WARN ]
javax.management.InstanceAlreadyExistsException
[ https://issues.apache.org/jira/browse/FLINK-24672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-24672:
-----------------------------------
Labels: pull-request-available (was: )
> [ WARN ] javax.management.InstanceAlreadyExistsException
> --------------------------------------------------------
>
> Key: FLINK-24672
> URL: https://issues.apache.org/jira/browse/FLINK-24672
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Kafka
> Affects Versions: 1.14.0
> Reporter: qinghuan wang
> Priority: Minor
> Labels: pull-request-available
>
> When Create 2 Kafka Tables with same group.id
>
> {code:java}
> CREATE TABLE table1 (
> ...
> ) WITH ( 'connector' = 'kafka',
> 'properties.group.id' = 'test-demo',
> ...
> );
> CREATE TABLE table2 (
> ...
> ) WITH ( 'connector' = 'kafka',
> 'properties.group.id' = 'test-demo',
> ...
> )
> {code}
>
> We will see warning
> {code:java}
> [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){code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)