[jira] [Resolved] (FLUME-2836) Flume and Cassandra sink

2015-11-04 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal resolved FLUME-2836. --- Resolution: Won't Fix ML question > Flume and Cassandra sink > > >

[jira] [Commented] (FLUME-2836) Flume and Cassandra sink

2015-11-04 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14989607#comment-14989607 ] Ashish Paliwal commented on FLUME-2836: --- Please ask questions on User Mailing lists

[jira] [Commented] (FLUME-2632) High CPU on KafkaSink

2015-10-21 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14967982#comment-14967982 ] Ashish Paliwal commented on FLUME-2632: --- It's a minor fix. Since I authored it, I ca

[jira] [Commented] (FLUME-2632) High CPU on KafkaSink

2015-10-16 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14961473#comment-14961473 ] Ashish Paliwal commented on FLUME-2632: --- [~jrufus]/[~hshreedharan]/[~gwenshap] Can a

[jira] [Commented] (FLUME-2437) S3 Source

2015-10-02 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941465#comment-14941465 ] Ashish Paliwal commented on FLUME-2437: --- [~jrufus] The patch needs rebasing. Could y

[jira] [Commented] (FLUME-2437) S3 Source

2015-10-01 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14940419#comment-14940419 ] Ashish Paliwal commented on FLUME-2437: --- Cool. [~hshreedharan] Do you have an concer

[jira] [Commented] (FLUME-2437) S3 Source

2015-10-01 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14940288#comment-14940288 ] Ashish Paliwal commented on FLUME-2437: --- [~jrufus] Shall we push this in as an exper

[jira] [Updated] (FLUME-2437) S3 Source

2015-10-01 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal updated FLUME-2437: -- Assignee: Johny Rufus (was: Ashish Paliwal) > S3 Source > - > > Key: FL

[jira] [Commented] (FLUME-2783) Update Website Team page with new Committer's

2015-09-16 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14790940#comment-14790940 ] Ashish Paliwal commented on FLUME-2783: --- +1 looks good. Pls go ahead and commit the

[jira] [Created] (FLUME-2783) Update Website Team page with new Committer's

2015-09-03 Thread Ashish Paliwal (JIRA)
Ashish Paliwal created FLUME-2783: - Summary: Update Website Team page with new Committer's Key: FLUME-2783 URL: https://issues.apache.org/jira/browse/FLUME-2783 Project: Flume Issue Type: Doc

[jira] [Commented] (FLUME-2765) ThriftSource spaws too many threads

2015-08-17 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699731#comment-14699731 ] Ashish Paliwal commented on FLUME-2765: --- Thanks ! I shall look into this whenever I

[jira] [Commented] (FLUME-2757) Hive Sink Tests failing due to incorrect permission on hive scratch dir

2015-08-14 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14697915#comment-14697915 ] Ashish Paliwal commented on FLUME-2757: --- Is it possible to use this API TemporaryFol

[jira] [Commented] (FLUME-2765) ThriftSource spaws too many threads

2015-08-14 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14697396#comment-14697396 ] Ashish Paliwal commented on FLUME-2765: --- A thread dump plus a simple test case that

[jira] [Commented] (FLUME-2498) Implement Taildir Source

2015-08-08 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14663052#comment-14663052 ] Ashish Paliwal commented on FLUME-2498: --- +1, I think once we have this gets committe

[jira] [Commented] (FLUME-2757) Hive Sink Tests failing due to incorrect permission on hive scratch dir

2015-08-07 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14662170#comment-14662170 ] Ashish Paliwal commented on FLUME-2757: --- Ok, a validation would be great. > Hive Si

[jira] [Commented] (FLUME-2757) Hive Sink Tests failing due to incorrect permission on hive scratch dir

2015-08-07 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14662159#comment-14662159 ] Ashish Paliwal commented on FLUME-2757: --- +1 Fix looks good to me. Do you want me to

[jira] [Commented] (FLUME-2753) Error when specifying empty replace string in Search and Replace Interceptor

2015-08-06 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14660597#comment-14660597 ] Ashish Paliwal commented on FLUME-2753: --- +1 Running the tests before committing >

[jira] [Commented] (FLUME-2753) Error when specifying empty replace string in Search and Replace Interceptor

2015-08-04 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654061#comment-14654061 ] Ashish Paliwal commented on FLUME-2753: --- Can we have a test case for this? > Error

[jira] [Commented] (FLUME-2660) Add documentation for EventValidator

2015-07-29 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14647004#comment-14647004 ] Ashish Paliwal commented on FLUME-2660: --- The site is updated, already has this fix

[jira] [Commented] (FLUME-2660) Add documentation for EventValidator

2015-07-29 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14646791#comment-14646791 ] Ashish Paliwal commented on FLUME-2660: --- [~jrufus] Fixed the build issue with the pa

[jira] [Updated] (FLUME-2660) Add documentation for EventValidator

2015-07-29 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal updated FLUME-2660: -- Attachment: FLUME-2660-1.patch > Add documentation for EventValidator >

[jira] [Reopened] (FLUME-2660) Add documentation for EventValidator

2015-07-29 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal reopened FLUME-2660: --- The patch has build issue, re opening > Add documentation for EventValidator > --

[jira] [Commented] (FLUME-2660) Add documentation for EventValidator

2015-07-23 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14639063#comment-14639063 ] Ashish Paliwal commented on FLUME-2660: --- [~jrufus] Can you take a quick look at this

[jira] [Commented] (FLUME-2746) How to include this Flume Patch in Flume 1.5.2 ?

2015-07-23 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14639052#comment-14639052 ] Ashish Paliwal commented on FLUME-2746: --- For #1 Download the source (not sure if you

[jira] [Commented] (FLUME-2053) TestExecSource.testMonitoredCounterGroup fails

2015-07-20 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14633958#comment-14633958 ] Ashish Paliwal commented on FLUME-2053: --- [~jrufus] Please go ahead > TestExecSource

[jira] [Commented] (FLUME-2713) Document Fault Tolerant Config parameters in FlumeUserGuide

2015-07-07 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14617900#comment-14617900 ] Ashish Paliwal commented on FLUME-2713: --- Thanks [~jrufus] Shall take care next time

[jira] [Commented] (FLUME-2713) Document Fault Tolerant Config parameters in FlumeUserGuide

2015-07-07 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14617814#comment-14617814 ] Ashish Paliwal commented on FLUME-2713: --- [~hshreedharan] I committed on both trunk a

[jira] [Commented] (FLUME-2713) Document Fault Tolerant Config parameters in FlumeUserGuide

2015-07-07 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14617807#comment-14617807 ] Ashish Paliwal commented on FLUME-2713: --- Sure, missed that part. +1 committing > D

[jira] [Commented] (FLUME-2632) High CPU on KafkaSink

2015-07-07 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14617692#comment-14617692 ] Ashish Paliwal commented on FLUME-2632: --- [~gwenshap] Can you have a look at it, mino

[jira] [Comment Edited] (FLUME-2632) High CPU on KafkaSink

2015-07-07 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14617692#comment-14617692 ] Ashish Paliwal edited comment on FLUME-2632 at 7/8/15 12:02 AM:

[jira] [Commented] (FLUME-2672) NPE in KafkaSourceCounter

2015-07-07 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14617453#comment-14617453 ] Ashish Paliwal commented on FLUME-2672: --- Getting an error while applying the patch.

[jira] [Commented] (FLUME-2672) NPE in KafkaSourceCounter

2015-07-06 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14615981#comment-14615981 ] Ashish Paliwal commented on FLUME-2672: --- Let me check and commit. > NPE in KafkaSou

[jira] [Commented] (FLUME-2736) issue in exporting flipkart data from web url to HDFS

2015-07-06 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14615357#comment-14615357 ] Ashish Paliwal commented on FLUME-2736: --- HTTP Source is not a pull source, you need

[jira] [Resolved] (FLUME-2736) issue in exporting flipkart data from web url to HDFS

2015-07-06 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal resolved FLUME-2736. --- Resolution: Invalid User ML Question > issue in exporting flipkart data from web url to HDFS

[jira] [Commented] (FLUME-2736) issue in exporting flipkart data from web url to HDFS

2015-07-05 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14614464#comment-14614464 ] Ashish Paliwal commented on FLUME-2736: --- Not sure what are you trying to achieve her

[jira] [Commented] (FLUME-2730) Flume execution time - configuration

2015-07-04 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14614015#comment-14614015 ] Ashish Paliwal commented on FLUME-2730: --- There is nothing in configuration that shal

[jira] [Commented] (FLUME-2729) Allow pollableSource backoff times to be configurable

2015-07-01 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610989#comment-14610989 ] Ashish Paliwal commented on FLUME-2729: --- Will be good to create a review request >

[jira] [Commented] (FLUME-2729) Allow pollableSource backoff times to be configurable

2015-06-25 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14602212#comment-14602212 ] Ashish Paliwal commented on FLUME-2729: --- It's just a suggestion :) I know Guava trou

[jira] [Commented] (FLUME-2729) Allow pollableSource backoff times to be configurable

2015-06-25 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14601601#comment-14601601 ] Ashish Paliwal commented on FLUME-2729: --- I didn't look much into the patch, but I di

[jira] [Created] (FLUME-2726) Remove * imports from Kafka Channel

2015-06-22 Thread Ashish Paliwal (JIRA)
Ashish Paliwal created FLUME-2726: - Summary: Remove * imports from Kafka Channel Key: FLUME-2726 URL: https://issues.apache.org/jira/browse/FLUME-2726 Project: Flume Issue Type: Bug

[jira] [Comment Edited] (FLUME-2720) HDFS Sink: Autogenerate LZO indexes while creating LZO files

2015-06-16 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588785#comment-14588785 ] Ashish Paliwal edited comment on FLUME-2720 at 6/16/15 9:13 PM:

[jira] [Commented] (FLUME-2720) HDFS Sink: Autogenerate LZO indexes while creating LZO files

2015-06-16 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588785#comment-14588785 ] Ashish Paliwal commented on FLUME-2720: --- IMHO we should have atleast some basic test

[jira] [Commented] (FLUME-2437) S3 Source

2015-06-11 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14582693#comment-14582693 ] Ashish Paliwal commented on FLUME-2437: --- I am tied up with my relocation. Would be g

[jira] [Commented] (FLUME-2661) Support timeout in ES Sink

2015-04-21 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14505027#comment-14505027 ] Ashish Paliwal commented on FLUME-2661: --- The problem is valid so let's keep this ope

[jira] [Commented] (FLUME-2672) NPE in KafkaSourceCounter

2015-04-15 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14496248#comment-14496248 ] Ashish Paliwal commented on FLUME-2672: --- +1, Patch looks good. May be we should have

[jira] [Updated] (FLUME-2672) NPE in KafkaSourceCounter

2015-04-15 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal updated FLUME-2672: -- Summary: NPE in KafkaSourceCounter (was: NPE in KafkaSinkCounter) > NPE in KafkaSourceCounter >

[jira] [Commented] (FLUME-2437) S3 Source

2015-04-09 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14487369#comment-14487369 ] Ashish Paliwal commented on FLUME-2437: --- I was thinking if we can push this as exper

[jira] [Commented] (FLUME-2437) S3 Source

2015-04-09 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486860#comment-14486860 ] Ashish Paliwal commented on FLUME-2437: --- [~jrufus] Did you get time to update the co

[jira] [Updated] (FLUME-2660) Add documentation for EventValidator

2015-04-07 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal updated FLUME-2660: -- Attachment: FLUME-2660-0.patch > Add documentation for EventValidator >

[jira] [Created] (FLUME-2661) Support timeout in ES Sink

2015-04-07 Thread Ashish Paliwal (JIRA)
Ashish Paliwal created FLUME-2661: - Summary: Support timeout in ES Sink Key: FLUME-2661 URL: https://issues.apache.org/jira/browse/FLUME-2661 Project: Flume Issue Type: Bug Componen

[jira] [Commented] (FLUME-2655) Monitoring should start before all other components

2015-04-06 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14482603#comment-14482603 ] Ashish Paliwal commented on FLUME-2655: --- IMHO, this is the correct behaviour, unless

[jira] [Updated] (FLUME-2635) Documentation for zookeeper dynamic configuration in flume

2015-04-02 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal updated FLUME-2635: -- Attachment: FLUME-2635-1.patch Updated as per review comments > Documentation for zookeeper dyn

[jira] [Commented] (FLUME-2635) Documentation for zookeeper dynamic configuration in flume

2015-03-24 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14377606#comment-14377606 ] Ashish Paliwal commented on FLUME-2635: --- [~roshan_naik] Welcome back :) Thanks for f

[jira] [Updated] (FLUME-2613) Tool/script for deleting individual message from queue

2015-03-16 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal updated FLUME-2613: -- Attachment: FLUME-2613-3.patch > Tool/script for deleting individual message from queue > --

[jira] [Commented] (FLUME-2613) Tool/script for deleting individual message from queue

2015-03-16 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14363305#comment-14363305 ] Ashish Paliwal commented on FLUME-2613: --- Handling for command line parameters added.

[jira] [Commented] (FLUME-2613) Tool/script for deleting individual message from queue

2015-03-15 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14362702#comment-14362702 ] Ashish Paliwal commented on FLUME-2613: --- Writing in customized format was in context

[jira] [Updated] (FLUME-2632) High CPU on KafkaSink

2015-03-15 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal updated FLUME-2632: -- Component/s: Sinks+Sources > High CPU on KafkaSink > - > > K

[jira] [Updated] (FLUME-2632) High CPU on KafkaSink

2015-03-15 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal updated FLUME-2632: -- Labels: kafka (was: ) > High CPU on KafkaSink > - > > Key:

[jira] [Commented] (FLUME-2437) S3 Source

2015-03-15 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14362276#comment-14362276 ] Ashish Paliwal commented on FLUME-2437: --- Published a few review comments, would need

[jira] [Updated] (FLUME-2632) High CPU on KafkaSink

2015-03-15 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal updated FLUME-2632: -- Attachment: FLUME-2632-0.patch > High CPU on KafkaSink > - > >

[jira] [Updated] (FLUME-2632) High CPU on KafkaSink

2015-03-15 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal updated FLUME-2632: -- Fix Version/s: 1.6 > High CPU on KafkaSink > - > > Key: FLUM

[jira] [Updated] (FLUME-2632) High CPU on KafkaSink

2015-03-15 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal updated FLUME-2632: -- Affects Version/s: v1.5.1 > High CPU on KafkaSink > - > > Ke

[jira] [Commented] (FLUME-2636) Agent wide context for configuring shareable properties

2015-03-14 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14362249#comment-14362249 ] Ashish Paliwal commented on FLUME-2636: --- ok found it https://issues.apache.org/jira/

[jira] [Commented] (FLUME-2437) S3 Source

2015-03-14 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14362226#comment-14362226 ] Ashish Paliwal commented on FLUME-2437: --- I did had a cursory look at the implementat

[jira] [Commented] (FLUME-2636) Agent wide context for configuring shareable properties

2015-03-14 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14362224#comment-14362224 ] Ashish Paliwal commented on FLUME-2636: --- https://issues.apache.org/jira/browse/FLUME

[jira] [Commented] (FLUME-2613) Tool/script for deleting individual message from queue

2015-03-14 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14362209#comment-14362209 ] Ashish Paliwal commented on FLUME-2613: --- Just a wild thought, The Event Validator im

[jira] [Updated] (FLUME-2613) Tool/script for deleting individual message from queue

2015-03-14 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal updated FLUME-2613: -- Attachment: FLUME-2613-2.patch Updated per review comments > Tool/script for deleting individua

[jira] [Commented] (FLUME-2613) Tool/script for deleting individual message from queue

2015-03-13 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14361637#comment-14361637 ] Ashish Paliwal commented on FLUME-2613: --- Updated as per comment. Now the tool is par

[jira] [Updated] (FLUME-2613) Tool/script for deleting individual message from queue

2015-03-13 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal updated FLUME-2613: -- Attachment: FLUME-2613-1.patch > Tool/script for deleting individual message from queue > --

[jira] [Commented] (FLUME-2613) Tool/script for deleting individual message from queue

2015-03-13 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360101#comment-14360101 ] Ashish Paliwal commented on FLUME-2613: --- Yup. The code shall be simple. Check would

[jira] [Commented] (FLUME-2613) Tool/script for deleting individual message from queue

2015-03-12 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14359774#comment-14359774 ] Ashish Paliwal commented on FLUME-2613: --- Yup we can do that. Let me get a patch with

[jira] [Commented] (FLUME-2413) Add a new metric for the number of bytes transferred on a flume channel

2015-03-11 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14358019#comment-14358019 ] Ashish Paliwal commented on FLUME-2413: --- [~hshreedharan] Any chances of this making

[jira] [Assigned] (FLUME-2413) Add a new metric for the number of bytes transferred on a flume channel

2015-03-11 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal reassigned FLUME-2413: - Assignee: Ashish Paliwal > Add a new metric for the number of bytes transferred on a flum

[jira] [Commented] (FLUME-2641) Drop Java 6 support post Flume 1.6

2015-03-11 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14358009#comment-14358009 ] Ashish Paliwal commented on FLUME-2641: --- +1, IMHO lets use JDK 8, with target versio

[jira] [Commented] (FLUME-2613) Tool/script for deleting individual message from queue

2015-03-11 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14356738#comment-14356738 ] Ashish Paliwal commented on FLUME-2613: --- Review request created, working on adding d

[jira] [Updated] (FLUME-2613) Tool/script for deleting individual message from queue

2015-03-11 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal updated FLUME-2613: -- Attachment: (was: FLUME-2613-0.patch) > Tool/script for deleting individual message from que

[jira] [Updated] (FLUME-2613) Tool/script for deleting individual message from queue

2015-03-11 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal updated FLUME-2613: -- Attachment: FLUME-2613-0.patch > Tool/script for deleting individual message from queue > --

[jira] [Updated] (FLUME-2613) Tool/script for deleting individual message from queue

2015-03-11 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal updated FLUME-2613: -- Attachment: FLUME-2613-0.patch > Tool/script for deleting individual message from queue > --

[jira] [Commented] (FLUME-2613) Tool/script for deleting individual message from queue

2015-03-10 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14356074#comment-14356074 ] Ashish Paliwal commented on FLUME-2613: --- Working on test cases, got caught in other

[jira] [Commented] (FLUME-2485) Thrift Source tests fail on Oracle JDK 8

2015-03-07 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14351910#comment-14351910 ] Ashish Paliwal commented on FLUME-2485: --- Ok, I ran into this issue on JDK 8. Can you

[jira] [Commented] (FLUME-2437) S3 Source

2015-03-06 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14351342#comment-14351342 ] Ashish Paliwal commented on FLUME-2437: --- Can you please share the Flume config (minu

[jira] [Commented] (FLUME-2485) Thrift Source tests fail on Oracle JDK 8

2015-03-04 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14346690#comment-14346690 ] Ashish Paliwal commented on FLUME-2485: --- Have you updated the pom.xml or just using

[jira] [Commented] (FLUME-2636) Agent wide context for configuring shareable properties

2015-03-02 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14344284#comment-14344284 ] Ashish Paliwal commented on FLUME-2636: --- There is a related JIRA for Agent level pro

[jira] [Updated] (FLUME-2635) Documentation for zookeeper dynamic configuration in flume

2015-03-01 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal updated FLUME-2635: -- Attachment: FLUME-2635-0.patch > Documentation for zookeeper dynamic configuration in flume > --

[jira] [Commented] (FLUME-2624) Improve Hive Sink performance

2015-03-01 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14342832#comment-14342832 ] Ashish Paliwal commented on FLUME-2624: --- Please update status to patch available and

[jira] [Commented] (FLUME-2298) Replication Channel

2015-02-27 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14341302#comment-14341302 ] Ashish Paliwal commented on FLUME-2298: --- [~ted.m] Can we mark this JIRA as resolved

[jira] [Assigned] (FLUME-2635) Documentation for zookeeper dynamic configuration in flume

2015-02-27 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal reassigned FLUME-2635: - Assignee: Ashish Paliwal > Documentation for zookeeper dynamic configuration in flume > -

[jira] [Commented] (FLUME-2613) Tool/script for deleting individual message from queue

2015-02-26 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14339527#comment-14339527 ] Ashish Paliwal commented on FLUME-2613: --- Yup, I thought the same but since I was not

[jira] [Commented] (FLUME-2613) Tool/script for deleting individual message from queue

2015-02-25 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14337951#comment-14337951 ] Ashish Paliwal commented on FLUME-2613: --- record.getEvent() returns TransactionEventR

[jira] [Commented] (FLUME-2613) Tool/script for deleting individual message from queue

2015-02-25 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14337937#comment-14337937 ] Ashish Paliwal commented on FLUME-2613: --- Are there any classes we can reuse from Fil

[jira] [Commented] (FLUME-2437) S3 Source

2015-02-21 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14330250#comment-14330250 ] Ashish Paliwal commented on FLUME-2437: --- Ok, Lets go with AWS SDK. I remember using

[jira] [Commented] (FLUME-2437) S3 Source

2015-02-20 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14330027#comment-14330027 ] Ashish Paliwal commented on FLUME-2437: --- Related question - Do we prefer Amazon SDK

[jira] [Commented] (FLUME-2437) S3 Source

2015-02-20 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14330024#comment-14330024 ] Ashish Paliwal commented on FLUME-2437: --- Where can I find ResettableGenericInputStre

[jira] [Commented] (FLUME-2437) S3 Source

2015-02-20 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14329047#comment-14329047 ] Ashish Paliwal commented on FLUME-2437: --- You got my question correctly. I pushed so

[jira] [Commented] (FLUME-2437) S3 Source

2015-02-20 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328899#comment-14328899 ] Ashish Paliwal commented on FLUME-2437: --- Quick question, how do the Users like to fe

[jira] [Commented] (FLUME-2498) Implement Taildir Source

2015-02-19 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328529#comment-14328529 ] Ashish Paliwal commented on FLUME-2498: --- Can't we add this as an experimental featur

[jira] [Commented] (FLUME-2437) S3 Source

2015-02-19 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328492#comment-14328492 ] Ashish Paliwal commented on FLUME-2437: --- Well I already started working on it yester

[jira] [Commented] (FLUME-1672) Add string support for metrics

2015-02-19 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-1672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328487#comment-14328487 ] Ashish Paliwal commented on FLUME-1672: --- Ahh, then it's not fixed. Not sure, but can

[jira] [Commented] (FLUME-2437) S3 Source

2015-02-19 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327382#comment-14327382 ] Ashish Paliwal commented on FLUME-2437: --- Did anyone had a chance to work on this? >

[jira] [Assigned] (FLUME-2437) S3 Source

2015-02-19 Thread Ashish Paliwal (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Paliwal reassigned FLUME-2437: - Assignee: Ashish Paliwal > S3 Source > - > > Key: FLUME-2437 >

  1   2   3   4   5   6   7   8   9   >