Strange... Can you share 1) JVM 2) OS and 3) Flume config file?
On Thu, Mar 21, 2013 at 7:54 AM, JR <[email protected]> wrote: > Hello, > > Am a newbie, trying to set up acvro source, channel memory and hdfs > sink. Am encountering the following error: Not sure > what to do. > > *Is there a way to 'search' the topics in the * > > 13/03/21 07:09:50 ERROR nodemanager.DefaultLogicalNodeManager: Error while > starting org.apache.flume.channel.MemoryChannel{name: ch1} > java.util.concurrent.RejectedExecutionException > at > java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1779) > at > java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:778) > at > java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:226) > at > java.util.concurrent.ScheduledThreadPoolExecutor.scheduleWithFixedDelay(ScheduledThreadPoolExecutor.java:454) > at > org.apache.flume.lifecycle.LifecycleSupervisor.supervise(LifecycleSupervisor.java:140) > at > org.apache.flume.node.nodemanager.DefaultLogicalNodeManager.startAllComponents(DefaultLogicalNodeManager.java:114) > at > org.apache.flume.conf.properties.PropertiesFileConfigurationProvider.load(PropertiesFileConfigurationProvider.java:225) > 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:452) > at > java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:328) > at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:161) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:109) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:191) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:215) > at > java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:897) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:919) > at java.lang.Thread.run(Thread.java:738) > 13/03/21 07:09:50 INFO nodemanager.DefaultLogicalNodeManager: Waiting for > channel: ch1 to start. Sleeping for 500 ms > 13/03/21 07:09:50 INFO nodemanager.DefaultLogicalNodeManager: Waiting for > channel: ch1 to start. Sleeping for 500 ms > -- Apache MRUnit - Unit testing MapReduce - http://incubator.apache.org/mrunit/
