Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Plain View
Flume, mail # user - using FQCN for interceptors fails


+
Allan Feid 2013-06-06, 19:01
Copy link to this message
-
Re: using FQCN for interceptors fails
Hari Shreedharan 2013-06-06, 19:07
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)