flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Hari Shreedharan <hshreedha...@cloudera.com>
Subject Re: using FQCN for interceptors fails
Date Thu, 06 Jun 2013 19:07:23 GMT
You need to use org.apache.flume.interceptor.StaticInterceptor$Builder as the FQCN. 



Cheers,
Hari


On Thursday, June 6, 2013 at 12:01 PM, Allan Feid wrote:

> Hello Everyone,
> 
> I've been trying to write my own custom interceptor, but ran into a problem when using
a FQCN for an interceptor type. The error happens with even the built in interceptor types
when using a FQCN. Here's what the trace looks like: 
> 
> 2013-06-06 14:47:18,025 (conf-file-poller-0) [ERROR - org.apache.flume.channel.ChannelProcessor.configureInterceptors(ChannelProcessor.java:116)]
Could not instantiate Builder. Exception follows. 
> java.lang.InstantiationException: org.apache.flume.interceptor.StaticInterceptor
>         at java.lang.Class.newInstance0(Class.java:359)
>         at java.lang.Class.newInstance(Class.java:327)
>         at org.apache.flume.interceptor.InterceptorBuilderFactory.newInstance(InterceptorBuilderFactory.java:48)
>         at org.apache.flume.channel.ChannelProcessor.configureInterceptors(ChannelProcessor.java:109)
>         at org.apache.flume.channel.ChannelProcessor.configure(ChannelProcessor.java:80)
>         at org.apache.flume.conf.Configurables.configure(Configurables.java:41)
>         at org.apache.flume.conf.properties.PropertiesFileConfigurationProvider.loadSources(PropertiesFileConfigurationProvider.java:337)
>         at org.apache.flume.conf.properties.PropertiesFileConfigurationProvider.load(PropertiesFileConfigurationProvider.java:222)
>         at org.apache.flume.conf.file.AbstractFileConfigurationProvider.doLoad(AbstractFileConfigurationProvider.java:123)
>         at org.apache.flume.conf.file.AbstractFileConfigurationProvider.access$300(AbstractFileConfigurationProvider.java:38)
>         at org.apache.flume.conf.file.AbstractFileConfigurationProvider$FileWatcherRunnable.run(AbstractFileConfigurationProvider.java:202)
>         at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
>         at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:351)
>         at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:178)
>         at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:165)
>         at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:267)
>         at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1146)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>         at java.lang.Thread.run(Thread.java:679)
> 2013-06-06 14:47:18,027 (conf-file-poller-0) [ERROR - org.apache.flume.conf.file.AbstractFileConfigurationProvider$FileWatcherRunnable.run(AbstractFileConfigurationProvider.java:204)]
Failed to load configuration data. Exception follows.
> org.apache.flume.FlumeException: Interceptor.Builder not constructable.
>         at org.apache.flume.channel.ChannelProcessor.configureInterceptors(ChannelProcessor.java:117)
>         at org.apache.flume.channel.ChannelProcessor.configure(ChannelProcessor.java:80)
>         at org.apache.flume.conf.Configurables.configure(Configurables.java:41)
>         at org.apache.flume.conf.properties.PropertiesFileConfigurationProvider.loadSources(PropertiesFileConfigurationProvider.java:337)
>         at org.apache.flume.conf.properties.PropertiesFileConfigurationProvider.load(PropertiesFileConfigurationProvider.java:222)
>         at org.apache.flume.conf.file.AbstractFileConfigurationProvider.doLoad(AbstractFileConfigurationProvider.java:123)
>         at org.apache.flume.conf.file.AbstractFileConfigurationProvider.access$300(AbstractFileConfigurationProvider.java:38)
>         at org.apache.flume.conf.file.AbstractFileConfigurationProvider$FileWatcherRunnable.run(AbstractFileConfigurationProvider.java:202)
>         at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
>         at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:351)
>         at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:178)
>         at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:165)
>         at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:267)
>         at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1146)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>         at java.lang.Thread.run(Thread.java:679)
> Caused by: java.lang.InstantiationException: org.apache.flume.interceptor.StaticInterceptor
>         at java.lang.Class.newInstance0(Class.java:359)
>         at java.lang.Class.newInstance(Class.java:327)
>         at org.apache.flume.interceptor.InterceptorBuilderFactory.newInstance(InterceptorBuilderFactory.java:48)
>         at org.apache.flume.channel.ChannelProcessor.configureInterceptors(ChannelProcessor.java:109)
>         ... 15 more
> 
> 
> Thanks,
> Allan
> 
> 
> 



Mime
View raw message