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 > > >
