Ok as soon as I can tomorrow. Thanks
On Tue, 25 Feb 2020 at 11:51, Khachatryan Roman <khachatryan.ro...@gmail.com> wrote: > 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) >> >
