qinghuan wang created FLINK-24672:
-------------------------------------
Summary: [ 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
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)
