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

Switch to Plain View
Flume >> mail # user >> Channel not starting.


+
JR 2013-03-21, 14:54
Copy link to this message
-
Re: Channel not starting.
Plz input your configuration file.

On Thursday, March 21, 2013, JR 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
>
--
Zhiwen Sun
+
Brock Noland 2013-03-21, 15:04
+
JR 2013-03-21, 16:07
+
Brock Noland 2013-03-21, 16:13