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

camel-hdfs component does not work in Fuse ESB 7.1 OSGi environment

    XMLWordPrintable

Details

    Description

      This is a clone of MR-619 as the bug is still present in current 7.1 release.

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

      18:10:25,746 | ERROR | xtenderThread-10 | ContextLoaderListener            | 113 - 
      org.springframework.osgi.extender - 1.2.1 | Application context refresh failed 
      (OsgiBundleXmlApplicationContext(bundle=test-hadoop_incoming, config=osgibundle:/META-INF/spring/*.xml))
      org.apache.camel.FailedToCreateProducerException: Failed to create Producer for endpoint: 
      Endpoint[hdfs://localhost:9000/simple-file?splitStrategy=IDLE%3A1000%2CBYTES%3A5]. Reason: 
      java.util.NoSuchElementException
      	at org.apache.camel.impl.ProducerCache.doGetProducer(ProducerCache.java:395)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.impl.ProducerCache.acquireProducer(ProducerCache.java:114)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.impl.ProducerCache.startProducer(ProducerCache.java:145)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.processor.SendProcessor.doStart(SendProcessor.java:175)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:62)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:52)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:62)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:52)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.processor.interceptor.TraceInterceptor.doStart(TraceInterceptor.java:358)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:62)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:52)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:62)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:52)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.processor.RedeliveryErrorHandler.doStart(RedeliveryErrorHandler.java:1056)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:41)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:28)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:62)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:52)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.processor.interceptor.DefaultChannel.doStart(DefaultChannel.java:152)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:62)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:52)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:85)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.processor.MulticastProcessor.doStart(MulticastProcessor.java:935)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:62)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:52)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:62)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:52)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.processor.UnitOfWorkProcessor.doStart(UnitOfWorkProcessor.java:88)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:62)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:52)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:62)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:52)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:73)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:78)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:62)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.impl.RouteService.startChildService(RouteService.java:322)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.impl.RouteService.warmUp(RouteService.java:151)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.impl.DefaultCamelContext.doWarmUpRoutes(DefaultCamelContext.java:1992)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:1920)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:1708)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:1589)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:1445)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.spring.SpringCamelContext.doStart(SpringCamelContext.java:179)[149:org.apache.camel.camel-spring:2.10.0.fuse-71-047]
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:1413)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.spring.SpringCamelContext.maybeStart(SpringCamelContext.java:228)[149:org.apache.camel.camel-spring:2.10.0.fuse-71-047]
      	at org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:118)[149:org.apache.camel.camel-spring:2.10.0.fuse-71-047]
      	at org.apache.camel.spring.CamelContextFactoryBean.onApplicationEvent(CamelContextFactoryBean.java:280)[149:org.apache.camel.camel-spring:2.10.0.fuse-71-047]
      	at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:97)[104:org.springframework.context:3.0.7.RELEASE]
      	at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:303)[104:org.springframework.context:3.0.7.RELEASE]
      	at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:911)[104:org.springframework.context:3.0.7.RELEASE]
      	at org.springframework.osgi.context.support.AbstractOsgiBundleApplicationContext.finishRefresh(AbstractOsgiBundleApplicationContext.java:235)[114:org.springframework.osgi.core:1.2.1]
      	at org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext$4.run(AbstractDelegatedExecutionApplicationContext.java:358)[114:org.springframework.osgi.core:1.2.1]
      	at org.springframework.osgi.util.internal.PrivilegedUtils.executeWithCustomTCCL(PrivilegedUtils.java:85)[114:org.springframework.osgi.core:1.2.1]
      	at org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext.completeRefresh(AbstractDelegatedExecutionApplicationContext.java:320)[114:org.springframework.osgi.core:1.2.1]
      	at org.springframework.osgi.extender.internal.dependencies.startup.DependencyWaiterApplicationContextExecutor$CompleteRefreshTask.run(DependencyWaiterApplicationContextExecutor.java:132)[113:org.springframework.osgi.extender:1.2.1]
      	at java.lang.Thread.run(Thread.java:680)[:1.6.0_39]
      Caused by: java.util.NoSuchElementException
      	at java.util.HashMap$HashIterator.nextEntry(HashMap.java:796)[:1.6.0_39]
      	at java.util.HashMap$KeyIterator.next(HashMap.java:828)[:1.6.0_39]
      	at org.apache.hadoop.security.UserGroupInformation.<init>(UserGroupInformation.java:430)[250:org.apache.servicemix.bundles.hadoop-core:1.0.3.1]
      	at org.apache.hadoop.security.UserGroupInformation.getCurrentUser(UserGroupInformation.java:452)[250:org.apache.servicemix.bundles.hadoop-core:1.0.3.1]
      	at org.apache.hadoop.fs.FileSystem$Cache$Key.<init>(FileSystem.java:1494)[250:org.apache.servicemix.bundles.hadoop-core:1.0.3.1]
      	at org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:1395)[250:org.apache.servicemix.bundles.hadoop-core:1.0.3.1]
      	at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:254)[250:org.apache.servicemix.bundles.hadoop-core:1.0.3.1]
      	at org.apache.camel.component.hdfs.HdfsInfo.<init>(HdfsInfo.java:36)[252:org.apache.camel.camel-hdfs:2.10.0.fuse-71-047]
      	at org.apache.camel.component.hdfs.HdfsOutputStream.createOutputStream(HdfsOutputStream.java:48)[252:org.apache.camel.camel-hdfs:2.10.0.fuse-71-047]
      	at org.apache.camel.component.hdfs.HdfsProducer.setupHdfs(HdfsProducer.java:134)[252:org.apache.camel.camel-hdfs:2.10.0.fuse-71-047]
      	at org.apache.camel.component.hdfs.HdfsProducer.doStart(HdfsProducer.java:98)[252:org.apache.camel.camel-hdfs:2.10.0.fuse-71-047]
      	at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:60)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:62)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	at org.apache.camel.impl.ProducerCache.doGetProducer(ProducerCache.java:393)[147:org.apache.camel.camel-core:2.10.0.fuse-71-047]
      	... 80 more
      

      Attachments

        Activity

          People

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

            Dates

              Created:
              Updated:
              Resolved: