Just curious is this the reason why also some jobs in the UI show their metrics and others do not?
Looking at 2 jobs, one displays how may bytes in and out it has received. While another one show all zeros. But I know it's working though. On Wed, 26 Feb 2020 at 11:19, John Smith <java.dev....@gmail.com> wrote: > This is what I got from the logs. > > 2020-02-25 00:13:38,124 WARN org.apache.kafka.common.utils.AppInfoParser > - Error registering AppInfo mbean > javax.management.InstanceAlreadyExistsException: > kafka.consumer:type=app-info,id=consumer-1 > 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.KafkaPartitionDiscoverer.initializeConnections(KafkaPartitionDiscoverer.java:58) > at > org.apache.flink.streaming.connectors.kafka.internals.AbstractPartitionDiscoverer.open(AbstractPartitionDiscoverer.java:94) > at > org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.open(FlinkKafkaConsumerBase.java:505) > at > org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36) > at > org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.initializeStateAndOpen(StreamTask.java:1007) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$0(StreamTask.java:454) > at > org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:94) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:449) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:461) > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:707) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:532) > at java.lang.Thread.run(Thread.java:748) > > > > > On Tue, 25 Feb 2020 at 15:50, John Smith <java.dev....@gmail.com> wrote: > >> 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) >>>> >>>
