Uploaded image for project: 'FUSE Mediation Router'
  1. FUSE Mediation Router
  2. MR-619

camel-hdfs component does not work inside OSGi

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • 2.9.0-fuse-01-xx
    • 2.9.0-fuse-00-00
    • None
    • None

      Attached is a camel-hdfs testcase which runs perfectly standalone but fails to startup when deployed into ESB 7.
      In ESB 7 the testcase raises:

      18:13:15,222 | ERROR | l Console Thread | BlueprintContainerImpl           | 9 - org.apache.aries.blueprint - 0.3.1.fuse-7-061 | 
      Unable to start blueprint container for bundle hadoop_incoming
      org.osgi.service.blueprint.container.ComponentDefinitionException: Unable to intialize bean blueprintContext
      	at org.apache.aries.blueprint.container.BeanRecipe.runBeanProcInit(BeanRecipe.java:640)[9:org.apache.aries.blueprint:0.3.1.fuse-7-061]
      	at org.apache.aries.blueprint.container.BeanRecipe.internalCreate(BeanRecipe.java:726)[9:org.apache.aries.blueprint:0.3.1.fuse-7-061]
      	at org.apache.aries.blueprint.di.AbstractRecipe.create(AbstractRecipe.java:64)[9:org.apache.aries.blueprint:0.3.1.fuse-7-061]
      	at org.apache.aries.blueprint.container.BlueprintRepository.createInstances(BlueprintRepository.java:219)[9:org.apache.aries.blueprint:0.3.1.fuse-7-061]
      	at org.apache.aries.blueprint.container.BlueprintRepository.createAll(BlueprintRepository.java:147)[9:org.apache.aries.blueprint:0.3.1.fuse-7-061]
      	at org.apache.aries.blueprint.container.BlueprintContainerImpl.instantiateEagerComponents(BlueprintContainerImpl.java:631)[9:org.apache.aries.blueprint:0.3.1.fuse-7-061]
      	at org.apache.aries.blueprint.container.BlueprintContainerImpl.doRun(BlueprintContainerImpl.java:337)[9:org.apache.aries.blueprint:0.3.1.fuse-7-061]
      	at org.apache.aries.blueprint.container.BlueprintContainerImpl.run(BlueprintContainerImpl.java:232)[9:org.apache.aries.blueprint:0.3.1.fuse-7-061]
      	at org.apache.aries.blueprint.container.BlueprintExtender.checkBundle(BlueprintExtender.java:325)[9:org.apache.aries.blueprint:0.3.1.fuse-7-061]
      	at org.apache.aries.blueprint.container.BlueprintExtender.bundleChanged(BlueprintExtender.java:244)[9:org.apache.aries.blueprint:0.3.1.fuse-7-061]
      	at org.apache.aries.blueprint.container.BlueprintExtender$BlueprintBundleTrackerCustomizer.modifiedBundle(BlueprintExtender.java:471)[9:org.apache.aries.blueprint:0.3.1.fuse-7-061]
      	at org.osgi.util.tracker.BundleTracker$Tracked.customizerModified(BundleTracker.java:495)[karaf.jar:2.2.5.fuse-7-061]
      	at org.osgi.util.tracker.BundleTracker$Tracked.customizerModified(BundleTracker.java:1)[karaf.jar:2.2.5.fuse-7-061]
      	at org.osgi.util.tracker.AbstractTracked.track(AbstractTracked.java:238)[karaf.jar:2.2.5.fuse-7-061]
      	at org.osgi.util.tracker.BundleTracker$Tracked.bundleChanged(BundleTracker.java:457)[karaf.jar:2.2.5.fuse-7-061]
      	at org.apache.felix.framework.util.EventDispatcher.invokeBundleListenerCallback(EventDispatcher.java:870)[org.apache.felix.framework-4.0.3.fuse-7-061.jar:]
      	at org.apache.felix.framework.util.EventDispatcher.fireEventImmediately(EventDispatcher.java:791)[org.apache.felix.framework-4.0.3.fuse-7-061.jar:]
      	at org.apache.felix.framework.util.EventDispatcher.fireBundleEvent(EventDispatcher.java:515)[org.apache.felix.framework-4.0.3.fuse-7-061.jar:]
      	at org.apache.felix.framework.Felix.fireBundleEvent(Felix.java:4321)[org.apache.felix.framework-4.0.3.fuse-7-061.jar:]
      	at org.apache.felix.framework.Felix.startBundle(Felix.java:1945)[org.apache.felix.framework-4.0.3.fuse-7-061.jar:]
      	at org.apache.felix.framework.BundleImpl.start(BundleImpl.java:947)[org.apache.felix.framework-4.0.3.fuse-7-061.jar:]
      	at org.apache.felix.framework.BundleImpl.start(BundleImpl.java:934)[org.apache.felix.framework-4.0.3.fuse-7-061.jar:]
      	at org.apache.karaf.shell.osgi.StartBundle.doExecute(StartBundle.java:33)[35:org.apache.karaf.shell.osgi:2.2.5.fuse-7-061]
      	at org.apache.karaf.shell.osgi.BundlesCommand.doExecute(BundlesCommand.java:37)[35:org.apache.karaf.shell.osgi:2.2.5.fuse-7-061]
      	at org.apache.karaf.shell.console.OsgiCommandSupport.execute(OsgiCommandSupport.java:38)[19:org.apache.karaf.shell.console:2.2.5.fuse-7-061]
      	at org.apache.felix.gogo.commands.basic.AbstractCommand.execute(AbstractCommand.java:35)[19:org.apache.karaf.shell.console:2.2.5.fuse-7-061]
      	at org.apache.felix.gogo.runtime.CommandProxy.execute(CommandProxy.java:78)[19:org.apache.karaf.shell.console:2.2.5.fuse-7-061]
      	at org.apache.felix.gogo.runtime.Closure.executeCmd(Closure.java:474)[19:org.apache.karaf.shell.console:2.2.5.fuse-7-061]
      	at org.apache.felix.gogo.runtime.Closure.executeStatement(Closure.java:400)[19:org.apache.karaf.shell.console:2.2.5.fuse-7-061]
      	at org.apache.felix.gogo.runtime.Pipe.run(Pipe.java:108)[19:org.apache.karaf.shell.console:2.2.5.fuse-7-061]
      	at org.apache.felix.gogo.runtime.Closure.execute(Closure.java:183)[19:org.apache.karaf.shell.console:2.2.5.fuse-7-061]
      	at org.apache.felix.gogo.runtime.Closure.execute(Closure.java:120)[19:org.apache.karaf.shell.console:2.2.5.fuse-7-061]
      	at org.apache.felix.gogo.runtime.CommandSessionImpl.execute(CommandSessionImpl.java:89)[19:org.apache.karaf.shell.console:2.2.5.fuse-7-061]
      	at org.apache.karaf.shell.console.jline.Console.run(Console.java:226)[19:org.apache.karaf.shell.console:2.2.5.fuse-7-061]
      	at java.lang.Thread.run(Thread.java:619)[:1.6.0_07]
      Caused by: org.apache.camel.FailedToCreateProducerException: Failed to create Producer for endpoint: 
      Endpoint[hdfs://192.168.240.128:9000/user/hadoop-user/simple-file?splitStrategy=IDLE%3A1000%2CBYTES%3A5]. 
      Reason: java.util.NoSuchElementException
      	at org.apache.camel.impl.ProducerCache.doGetProducer(ProducerCache.java:381)
      	at org.apache.camel.impl.ProducerCache.acquireProducer(ProducerCache.java:108)
      	at org.apache.camel.impl.ProducerCache.startProducer(ProducerCache.java:139)
      	at org.apache.camel.processor.SendProcessor.doStart(SendProcessor.java:168)
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:49)
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:70)
      	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:49)
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:70)
      	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)
      	at org.apache.camel.processor.interceptor.TraceInterceptor.doStart(TraceInterceptor.java:358)
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:49)
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:70)
      	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:49)
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:70)
      	at org.apache.camel.processor.RedeliveryErrorHandler.doStart(RedeliveryErrorHandler.java:1040)
      	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:41)
      	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:28)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:49)
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:70)
      	at org.apache.camel.processor.interceptor.DefaultChannel.doStart(DefaultChannel.java:151)
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:49)
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:82)
      	at org.apache.camel.processor.MulticastProcessor.doStart(MulticastProcessor.java:934)
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:49)
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:70)
      	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:49)
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:70)
      	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)
      	at org.apache.camel.processor.UnitOfWorkProcessor.doStart(UnitOfWorkProcessor.java:88)
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:49)
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:70)
      	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:49)
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:70)
      	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
      	at org.apache.camel.impl.RouteService.startChildService(RouteService.java:323)
      	at org.apache.camel.impl.RouteService.warmUp(RouteService.java:152)
      	at org.apache.camel.impl.DefaultCamelContext.doWarmUpRoutes(DefaultCamelContext.java:1921)
      	at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:1849)
      	at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:1642)
      	at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:1531)
      	at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:1413)
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)
      	at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:1381)
      	at org.apache.camel.blueprint.BlueprintCamelContext.maybeStart(BlueprintCamelContext.java:90)
      	at org.apache.camel.blueprint.BlueprintCamelContext.init(BlueprintCamelContext.java:82)
      	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)[:1.6.0_07]
      	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)[:1.6.0_07]
      	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)[:1.6.0_07]
      	at java.lang.reflect.Method.invoke(Method.java:597)[:1.6.0_07]
      	at org.apache.aries.blueprint.utils.ReflectionUtils.invoke(ReflectionUtils.java:225)[9:org.apache.aries.blueprint:0.3.1.fuse-7-061]
      	at org.apache.aries.blueprint.container.BeanRecipe.invoke(BeanRecipe.java:838)[9:org.apache.aries.blueprint:0.3.1.fuse-7-061]
      	at org.apache.aries.blueprint.container.BeanRecipe.runBeanProcInit(BeanRecipe.java:638)[9:org.apache.aries.blueprint:0.3.1.fuse-7-061]
      	... 34 more
      Caused by: java.util.NoSuchElementException
      	at java.util.HashMap$HashIterator.nextEntry(HashMap.java:796)[:1.6.0_07]
      	at java.util.HashMap$KeyIterator.next(HashMap.java:828)[:1.6.0_07]
      	at org.apache.hadoop.security.UserGroupInformation.<init>(UserGroupInformation.java:374)
      	at org.apache.hadoop.security.UserGroupInformation.getCurrentUser(UserGroupInformation.java:395)
      	at org.apache.hadoop.fs.FileSystem$Cache$Key.<init>(FileSystem.java:1418)
      	at org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:1319)
      	at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:226)
      	at org.apache.camel.component.hdfs.HdfsInfo.<init>(HdfsInfo.java:34)
      	at org.apache.camel.component.hdfs.HdfsOutputStream.createOutputStream(HdfsOutputStream.java:48)
      	at org.apache.camel.component.hdfs.HdfsProducer.doStart(HdfsProducer.java:93)
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
      	at org.apache.camel.impl.ProducerCache.doGetProducer(ProducerCache.java:379)
      	... 110 more
      

            cibsen@redhat.com Claus Ibsen
            rhn-support-tmielke Torsten Mielke
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

              Created:
              Updated:
              Resolved: