Based on a quick search I think it has to do with the way how you use
Spring to package your "HikariDataSource".

Does this SO link help:
https://stackoverflow.com/questions/27440985/unable-to-register-mbean-hikaridatasource-hikaripool-0-with-key-datasource
?



On Thu, May 10, 2018 at 8:41 AM, chandresh pancholi <
chandreshpancholi...@gmail.com> wrote:

> Hi,
>
> I am building data consumer using Flink + Spring boot + Mysql + Kafka +
> Elasticsearch. I am using mvn clean package command to create a jar and
> submitting it to task manager on Kubernetes.
> The same jar works perfectly in local.
>
> I am adding the exception shown in task manager logs.
>
> Please help me out. I tried everything :( :(
>
> java.util.concurrent.CompletionException: 
> org.apache.flink.util.FlinkException: Could not run the jar.
>       at 
> org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleJsonRequest$0(JarRunHandler.java:90)
>       at 
> java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590)
>       at 
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
>       at java.util.concurrent.FutureTask.run(FutureTask.java:266)
>       at 
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
>       at 
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
>       at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
>       at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
>       at java.lang.Thread.run(Thread.java:748)
> Caused by: org.apache.flink.util.FlinkException: Could not run the jar.
>       ... 9 more
> Caused by: org.apache.flink.client.program.ProgramInvocationException: The 
> main method caused an error.
>       at 
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:542)
>       at 
> org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:417)
>       at 
> org.apache.flink.client.program.OptimizerPlanEnvironment.getOptimizedPlan(OptimizerPlanEnvironment.java:83)
>       at 
> org.apache.flink.client.program.ClusterClient.getOptimizedPlan(ClusterClient.java:334)
>       at 
> org.apache.flink.runtime.webmonitor.handlers.JarActionHandler.getJobGraphAndClassLoader(JarActionHandler.java:87)
>       at 
> org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleJsonRequest$0(JarRunHandler.java:69)
>       ... 8 more
> Caused by: java.lang.reflect.InvocationTargetException
>       at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>       at 
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
>       at 
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>       at java.lang.reflect.Method.invoke(Method.java:498)
>       at 
> org.springframework.boot.loader.MainMethodRunner.run(MainMethodRunner.java:48)
>       at org.springframework.boot.loader.Launcher.launch(Launcher.java:87)
>       at org.springframework.boot.loader.Launcher.launch(Launcher.java:50)
>       at org.springframework.boot.loader.JarLauncher.main(JarLauncher.java:51)
>       at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>       at 
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
>       at 
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>       at java.lang.reflect.Method.invoke(Method.java:498)
>       at 
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:525)
>       ... 13 more
> Caused by: org.springframework.jmx.export.UnableToRegisterMBeanException: 
> Unable to register MBean [HikariDataSource (HikariPool-9)] with key 
> 'dataSource'; nested exception is 
> javax.management.InstanceAlreadyExistsException: 
> com.zaxxer.hikari:name=dataSource,type=HikariDataSource
>       at 
> org.springframework.jmx.export.MBeanExporter.registerBeanNameOrInstance(MBeanExporter.java:626)
>       at 
> org.springframework.jmx.export.MBeanExporter.lambda$registerBeans$2(MBeanExporter.java:552)
>       at java.util.HashMap.forEach(HashMap.java:1289)
>       at 
> org.springframework.jmx.export.MBeanExporter.registerBeans(MBeanExporter.java:552)
>       at 
> org.springframework.jmx.export.MBeanExporter.afterSingletonsInstantiated(MBeanExporter.java:435)
>       at 
> org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:777)
>       at 
> org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:868)
>       at 
> org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:549)
>       at 
> org.springframework.boot.SpringApplication.refresh(SpringApplication.java:752)
>       at 
> org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:388)
>       at 
> org.springframework.boot.SpringApplication.run(SpringApplication.java:327)
>       at 
> org.springframework.boot.SpringApplication.run(SpringApplication.java:1246)
>       at 
> org.springframework.boot.SpringApplication.run(SpringApplication.java:1234)
>       at com.ailiens.thanos.ThanosApplication.main(ThanosApplication.java:15)
>       ... 26 more
> Caused by: javax.management.InstanceAlreadyExistsException: 
> com.zaxxer.hikari:name=dataSource,type=HikariDataSource
>       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.springframework.jmx.support.MBeanRegistrationSupport.doRegister(MBeanRegistrationSupport.java:137)
>       at 
> org.springframework.jmx.export.MBeanExporter.registerBeanInstance(MBeanExporter.java:672)
>       at 
> org.springframework.jmx.export.MBeanExporter.registerBeanNameOrInstance(MBeanExporter.java:616)
>       ... 39 more
>
>
>
> --
> Chandresh Pancholi
> Senior Software Engineer
> Flipkart.com
> Email-id:chandresh.panch...@flipkart.com
> Contact:08951803660
>

Reply via email to