Hi John, Seems like this is another instance of https://issues.apache.org/jira/browse/FLINK-8093 Could you please provide the full stacktrace?
Regards, Roman On Mon, Feb 24, 2020 at 10:48 PM John Smith <java.dev....@gmail.com> wrote: > Hi. Just upgraded to 1.10.0 And getting the bellow error when I deploy my > tasks. > > The first 1 seems to deploy ok, but subsequent ones seem to this throw > this error. But The seem to work still. > > javax.management.InstanceAlreadyExistsException: > kafka.consumer:type=app-info,id=consumer-2 > at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437) > at > com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898) > at > com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966) > at > com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900) > at > com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324) > at > com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522) > at > org.apache.kafka.common.utils.AppInfoParser.registerAppInfo(AppInfoParser.java:62) > at > org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:805) > at > org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:659) > at > org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:639) > at > org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerThread.getConsumer(KafkaConsumerThread.java:477) > at > org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerThread.run(KafkaConsumerThread.java:167) >
