Return-Path: X-Original-To: apmail-flume-user-archive@www.apache.org Delivered-To: apmail-flume-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 04F8FF00B for ; Thu, 21 Mar 2013 15:05:12 +0000 (UTC) Received: (qmail 66274 invoked by uid 500); 21 Mar 2013 15:05:11 -0000 Delivered-To: apmail-flume-user-archive@flume.apache.org Received: (qmail 66239 invoked by uid 500); 21 Mar 2013 15:05:11 -0000 Mailing-List: contact user-help@flume.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flume.apache.org Delivered-To: mailing list user@flume.apache.org Received: (qmail 66231 invoked by uid 99); 21 Mar 2013 15:05:11 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 21 Mar 2013 15:05:11 +0000 X-ASF-Spam-Status: No, hits=1.7 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of pensz01@gmail.com designates 209.85.216.43 as permitted sender) Received: from [209.85.216.43] (HELO mail-qa0-f43.google.com) (209.85.216.43) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 21 Mar 2013 15:05:04 +0000 Received: by mail-qa0-f43.google.com with SMTP id l8so1360718qaq.2 for ; Thu, 21 Mar 2013 08:04:44 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:x-received:in-reply-to:references:date:message-id :subject:from:to:content-type; bh=IMHOU+NOa/xTD4pm6MAeFqpM/SvdCjHimMXbhRevslE=; b=fc2WYc4oB/BNCMPmo4y7qevtPYTueC7tcEsMa9BIMUGWpBnPPLlyThmrtjeYeNoHBe CAOD4BODOa6MyjHvGdq3Rko43H9Z20uVfqbo9S38+fPaAsQUWvcBZXgzzBukMni64BB4 OCe+lQcrdd/v6tHuuk+LyCmmsoBreexhBlcMfNjbhzuAo3WoopMB/WeAVLTwX56P2eGi z1ReuQfaIsMq+iG7Aws7N3niawwcyFc2HdXUYYkruEYm6ymg2ZRLu3vf+DoLaITCz0yt E5F+v/sD5UDr7dcmusxNYj3Mk0oiPMsMFRFCh1/w5e5bTEjSM9N+qTtbRdVYFxYcHj0L wDvA== MIME-Version: 1.0 X-Received: by 10.49.118.137 with SMTP id km9mr11212961qeb.34.1363878283885; Thu, 21 Mar 2013 08:04:43 -0700 (PDT) Received: by 10.229.75.130 with HTTP; Thu, 21 Mar 2013 08:04:43 -0700 (PDT) In-Reply-To: References: Date: Thu, 21 Mar 2013 23:04:43 +0800 Message-ID: Subject: Re: Channel not starting. From: Zhiwen Sun To: "user@flume.apache.org" Content-Type: multipart/alternative; boundary=047d7b6d9bf0a0c31b04d870a8aa X-Virus-Checked: Checked by ClamAV on apache.org --047d7b6d9bf0a0c31b04d870a8aa Content-Type: text/plain; charset=ISO-8859-1 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 --047d7b6d9bf0a0c31b04d870a8aa Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable Plz input your configuration file.

On Thursday, March 2= 1, 2013, JR wrote:
Hello,

=A0=A0 Am a newbie, trying to set up acvro source,= channel memory and hdfs sink. Am encountering the following error: Not sur= e
what to do.

=A0=A0 Is there a way to 'search= ' the topics in the

13/03/21 07:09:50 ERROR nodemanager.DefaultL= ogicalNodeManager: Error while starting org.apache.flume.channel.MemoryChan= nel{name: ch1}
java.util.concurrent.RejectedExecutionException
= at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(= ThreadPoolExecutor.java:1779)
at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecuto= r.java:778)
at java.util.concurrent.ScheduledThreadPoolExecutor.= delayedExecute(ScheduledThreadPoolExecutor.java:226)
at java.uti= l.concurrent.ScheduledThreadPoolExecutor.scheduleWithFixedDelay(ScheduledTh= readPoolExecutor.java:454)
at org.apache.flume.lifecycle.LifecycleSupervisor.supervise(Lifecyc= leSupervisor.java:140)
at org.apache.flume.node.nodemanager.Defa= ultLogicalNodeManager.startAllComponents(DefaultLogicalNodeManager.java:114= )
at org.apache.flume.conf.properties.PropertiesFileConfigurationProv= ider.load(PropertiesFileConfigurationProvider.java:225)
at org.a= pache.flume.conf.file.AbstractFileConfigurationProvider.doLoad(AbstractFile= ConfigurationProvider.java:123)
at org.apache.flume.conf.file.AbstractFileConfigurationProvider.acc= ess$300(AbstractFileConfigurationProvider.java:38)
at org.apache= .flume.conf.file.AbstractFileConfigurationProvider$FileWatcherRunnable.run(= AbstractFileConfigurationProvider.java:202)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.ja= va:452)
at java.util.concurrent.FutureTask$Sync.innerRunAndReset= (FutureTask.java:328)
at java.util.concurrent.FutureTask.runAndR= eset(FutureTask.java:161)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFuture= Task.access$101(ScheduledThreadPoolExecutor.java:109)
at java.ut= il.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(S= cheduledThreadPoolExecutor.java:191)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFuture= Task.run(ScheduledThreadPoolExecutor.java:215)
at java.util.conc= urrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:897)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExe= cutor.java:919)
at java.lang.Thread.run(Thread.java:738)
13/0= 3/21 07:09:50 INFO nodemanager.DefaultLogicalNodeManager: Waiting for chann= el: ch1 to start. Sleeping for 500 ms
13/03/21 07:09:50 INFO nodemanager.DefaultLogicalNodeManager: Waiting for c= hannel: ch1 to start. Sleeping for 500 ms


--
Zhiwen Sun


--047d7b6d9bf0a0c31b04d870a8aa--