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 546B910FDC for ; Fri, 6 Sep 2013 10:30:09 +0000 (UTC) Received: (qmail 81106 invoked by uid 500); 6 Sep 2013 10:30:07 -0000 Delivered-To: apmail-flume-user-archive@flume.apache.org Received: (qmail 81011 invoked by uid 500); 6 Sep 2013 10:30:00 -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 80974 invoked by uid 99); 6 Sep 2013 10:29:58 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 06 Sep 2013 10:29:58 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of deep0mal@gmail.com designates 209.85.216.179 as permitted sender) Received: from [209.85.216.179] (HELO mail-qc0-f179.google.com) (209.85.216.179) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 06 Sep 2013 10:29:52 +0000 Received: by mail-qc0-f179.google.com with SMTP id l4so1575037qcv.24 for ; Fri, 06 Sep 2013 03:29:32 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:date:message-id:subject:from:to:content-type; bh=+cYm+TP77ruBjEJ6wPO5fhA1bQwJiDjAsJT042djrYc=; b=tcvLs5TvCfrKwVbJFBy7estxd7/AE/RS9Q0+/gU9wdUxnygzN2dMiE3mirECEzbcsv pfV4lJbIdFTJCG5S98V3K19XAl71sMsM5IEqAlOGrI0ZJYnyymyYTBEJO7Vl51B6kGIP Evb2Pmv2OliZaRBvWL2ol1A3dhBRdKlFZzIBPBHrmV6qqF/r6ghUtMYFMLBN0sOLXFHh qYmwjUybeNTx3gpu86JJO37MfHnlE2vJ05drIDVWF4U38SAUrPlMU+ZjkvTLSZHg8+KY QBhAwKrLxJYEjPjWUlbX8MoOtKF0qI9xQaGUOiNjw+LGylsM5JACQjf0o9zMhmJ01Pbc O5oA== MIME-Version: 1.0 X-Received: by 10.224.45.135 with SMTP id e7mr117084qaf.108.1378463372126; Fri, 06 Sep 2013 03:29:32 -0700 (PDT) Received: by 10.49.58.74 with HTTP; Fri, 6 Sep 2013 03:29:32 -0700 (PDT) Date: Fri, 6 Sep 2013 15:59:32 +0530 Message-ID: Subject: Changing capacity configuration of File channel throws IllegalStateException From: Deepesh Malviya To: user@flume.apache.org Content-Type: multipart/alternative; boundary=001a11c35a78a1b98004e5b483a6 X-Virus-Checked: Checked by ClamAV on apache.org --001a11c35a78a1b98004e5b483a6 Content-Type: text/plain; charset=ISO-8859-1 Hi, When I am trying to increase the configuration of capacity of the File channel from default value, it is resulting in following exception. What could be the issue? 06 Sep 2013 10:27:01,086 ERROR [SinkRunner-PollingRunner-DefaultSinkProcessor] (org.apache.flume.SinkRunner$PollingRunner.run:160) - Unable to deliver event. Exception follows. java.lang.IllegalStateException: Channel closed [channel=flumeChannel]. Due to java.lang.NegativeArraySizeException: null at org.apache.flume.channel.file.FileChannel.createTransaction(FileChannel.java:352) at org.apache.flume.channel.BasicChannelSemantics.getTransaction(BasicChannelSemantics.java:122) at org.apache.flume.sink.hdfs.HDFSEventSink.process(HDFSEventSink.java:344) at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68) at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147) at java.lang.Thread.run(Thread.java:679) Caused by: java.lang.NegativeArraySizeException at org.apache.flume.channel.file.EventQueueBackingStoreFile.allocate(EventQueueBackingStoreFile.java:366) at org.apache.flume.channel.file.EventQueueBackingStoreFile.(EventQueueBackingStoreFile.java:87) at org.apache.flume.channel.file.EventQueueBackingStoreFileV3.(EventQueueBackingStoreFileV3.java:49) at org.apache.flume.channel.file.EventQueueBackingStoreFactory.get(EventQueueBackingStoreFactory.java:70) at org.apache.flume.channel.file.Log.replay(Log.java:412) at org.apache.flume.channel.file.FileChannel.start(FileChannel.java:302) at org.apache.flume.lifecycle.LifecycleSupervisor$MonitorRunnable.run(LifecycleSupervisor.java:251) 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) ... 1 more -- _Deepesh --001a11c35a78a1b98004e5b483a6 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable
Hi,

When I= am trying to increase the configuration of capacity of the File channel fr= om default value, it is resulting in following exception. What could be the= issue?

06 Sep 2013 10:27:01,086 ERROR [SinkRunner-PollingRunne= r-DefaultSinkProcessor] (org.apache.flume.SinkRunner$PollingRunner.run:160)= =A0- Unable to deliver event. Exception follows.
java.lang.Illeg= alStateException: Channel closed [channel=3DflumeChannel]. Due to java.lang= .NegativeArraySizeException: null
at org.apache.flume= .channel.file.FileChannel.createTransaction(FileChannel.java:352)
at org.apache.flume.cha= nnel.BasicChannelSemantics.getTransaction(BasicChannelSemantics.java:122)
at org.apache.flume= .sink.hdfs.HDFSEventSink.process(HDFSEventSink.java:344)
at org.apache.flume.sink.Default= SinkProcessor.process(DefaultSinkProcessor.java:68)
at org.apache.flume= .SinkRunner$PollingRunner.run(SinkRunner.java:147)
at java.lang.Thread.run(Thread.java:67= 9)
Caused by: java.lang.NegativeArraySizeException
at org.apache.flume.channel.file.Ev= entQueueBackingStoreFile.allocate(EventQueueBackingStoreFile.java:366)
at org.apache.flume= .channel.file.EventQueueBackingStoreFile.<init>(EventQueueBackingStor= eFile.java:87)
at org.apache.flume.channel.file.EventQueueBackingStoreFileV3.<init>= (EventQueueBackingStoreFileV3.java:49)
at org.apache.flume= .channel.file.EventQueueBackingStoreFactory.get(EventQueueBackingStoreFacto= ry.java:70)
at= org.apache.flume.channel.file.Log.replay(Log.java:412)
at org.apache.flume= .channel.file.FileChannel.start(FileChannel.java:302)
at org.apache.flume.lifecycle.Lifec= ycleSupervisor$MonitorRunnable.run(LifecycleSupervisor.java:251)
at java.util.concur= rent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTas= k$Sync.innerRunAndReset(FutureTask.java:351)
at java.util.concur= rent.FutureTask.runAndReset(FutureTask.java:178)
at java.util.concurrent.ScheduledThreadP= oolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java= :165)
at java.util.concur= rent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoo= lExecutor.java:267)
<= /span>at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecut= or.java:1146)
at java.util.concur= rent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
<= span class=3D"" style=3D"white-space:pre"> ... 1 more

=
--
_Deepesh
--001a11c35a78a1b98004e5b483a6--