You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "qinghuan wang (Jira)" <ji...@apache.org> on 2021/10/27 17:08:00 UTC
[jira] [Created] (FLINK-24672) [ WARN ]
javax.management.InstanceAlreadyExistsException
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)