/repository.apache.org/content/repositories/orgapacheflume-1045.
>
> Distribution archives:
> https://dist.apache.org/repos/dist/dev/flume/flume-spring-boot
>
> You may download all the Maven artifacts by executing:
> wget -e robots=off --cut-dirs=7 -nH -r -p -np --no-check-certificate
> https://repository.apache.org/content/repositories/orgapacheflume-1045/org/apache/flume/
>
> Ralph
--
thanks
ashish
s://repository.apache.org/content/repositories/orgapacheflume-1037.
>
> Distribution archives: https://dist.apache.org/repos/dist/dev/flume/
>
> You may download all the Maven artifacts by executing:
> wget -e robots=off --cut-dirs=7 -nH -r -p -np --no-check-certificate
> https://repository.apache.org/content/repositories/orgapacheflume-1037/org/apache/flume/
>
> Ralph
--
thanks
ashish
Just in case someone is still interested, here is a webinar from
Streamsets that covers it
http://go.streamsets.com/opensourceingest.html
On Wed, Feb 11, 2015 at 8:32 PM, Ashish <paliwalash...@gmail.com> wrote:
> Has anyone in the list compared Flume to incubating Apache Nifi?
>
&
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/41702/#review125723
---
Ship it!
Ship It!
- Ashish Singh
On March 28, 2016, 7:02
/flume/source/kafka/KafkaSourceEmbeddedKafka.java
(line 46)
<https://reviews.apache.org/r/41702/#comment188571>
No, we should never do this. Please use Runtime exception instead.
- Ashish Singh
On March 28, 2016, 5:42 p.m., Grigoriy Rozhkov
> On March 28, 2016, 4:26 p.m., Ashish Singh wrote:
> > Ship It!
Just one minor comment and we are good to go. Thanks for the awesome work
Grigoriy!
- Ashish
---
This is an automatically generated e-mail. To reply, vis
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/41702/#review125668
---
Ship it!
Ship It!
- Ashish Singh
On March 28, 2016, 9:38
/flume/source/kafka/KafkaSourceEmbeddedKafka.java
(line 45)
<https://reviews.apache.org/r/41702/#comment188535>
If we can not get host, I do not think we can continue with the tests. We
should throw an exception here.
- Ashish Singh
On March 28, 2016, 9:38 a.m., Grigoriy Rozhkov
Maybe add a test to verify that regex is given priority over topics list
for subscribing.
- Ashish Singh
On March 24, 2016, 6:26 p.m., Grigoriy Rozhkov wrote:
>
> ---
> This is an automatically generated e-mail. To reply
me-ng-sources/flume-kafka-source/src/test/java/org/apache/flume/source/kafka/TestKafkaSource.java
(line 89)
<https://reviews.apache.org/r/41702/#comment187895>
Can we break this into multiple smaller tests? Would it make sense to do so?
- Ashish Singh
On March 23, 2016, 4:59 p.m., Grigo
iews, it certainly is better
> than using patches on jiras. We already get a lot of review requests
> as Pull Requests anyway. I'd like some community feedback on this.
>
> I think we'd need a vote before we can get it done.
>
> Thanks!
> Hari
--
thanks
ashish
Blog: http://www.as
CSRF) attacks. Wanted to double check
> with others if that is correct ?
>
> -roshan
--
thanks
ashish
Blog: http://www.ashishpaliwal.com/blog
My Photo Galleries: http://www.pbase.com/ashishpaliwal
[
https://issues.apache.org/jira/browse/FLUME-2836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14989607#comment-14989607
]
Ashish Paliwal commented on FLUME-2836:
---
Please ask questions on User Mailing lists
> Fl
[
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 s
[
https://issues.apache.org/jira/browse/FLUME-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14967982#comment-14967982
]
Ashish Paliwal commented on FLUME-2632:
---
It's a minor fix. Since I authored it, I cannot commit
>
> Please join me in congratulating Hari on his appointment and welcoming him
> to this role.
>
> Regards,
> Arvind Prabhakar
--
thanks
ashish
Blog: http://www.ashishpaliwal.com/blog
My Photo Galleries: http://www.pbase.com/ashishpaliwal
[
https://issues.apache.org/jira/browse/FLUME-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14961473#comment-14961473
]
Ashish Paliwal commented on FLUME-2632:
---
[~jrufus]/[~hshreedharan]/[~gwenshap] Can anyone of you
[
https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14941465#comment-14941465
]
Ashish Paliwal commented on FLUME-2437:
---
[~jrufus] The patch needs rebasing. Could you please look
[
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
> -
>
>
[
https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14940419#comment-14940419
]
Ashish Paliwal commented on FLUME-2437:
---
Cool. [~hshreedharan] Do you have an concerns/suggestions
[
https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14940288#comment-14940288
]
Ashish Paliwal commented on FLUME-2437:
---
[~jrufus] Shall we push this in as an experimental source
and no new
>> files were added.
>> Why?
>> Also, if I use the --staged flag only new file are included.
>> What am I missing?
>> Eran
>> --
>> Eran | "You don't need eyes to see, you need vision" (Faithless)
--
thanks
ashish
Blog: http://www.ashishpaliwal.com/blog
My Photo Galleries: http://www.pbase.com/ashishpaliwal
[
https://issues.apache.org/jira/browse/FLUME-2783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14790940#comment-14790940
]
Ashish Paliwal commented on FLUME-2783:
---
+1 looks good. Pls go ahead and commit the changes
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
[
https://issues.apache.org/jira/browse/FLUME-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699731#comment-14699731
]
Ashish Paliwal commented on FLUME-2765:
---
Thanks ! I shall look into this whenever I
[
https://issues.apache.org/jira/browse/FLUME-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697396#comment-14697396
]
Ashish Paliwal commented on FLUME-2765:
---
A thread dump plus a simple test case
[
https://issues.apache.org/jira/browse/FLUME-2757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14697915#comment-14697915
]
Ashish Paliwal commented on FLUME-2757:
---
Is it possible to use this API
[
https://issues.apache.org/jira/browse/FLUME-2498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14663052#comment-14663052
]
Ashish Paliwal commented on FLUME-2498:
---
+1, I think once we have this gets
[
https://issues.apache.org/jira/browse/FLUME-2757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14662159#comment-14662159
]
Ashish Paliwal commented on FLUME-2757:
---
+1 Fix looks good to me. Do you want me
[
https://issues.apache.org/jira/browse/FLUME-2757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14662170#comment-14662170
]
Ashish Paliwal commented on FLUME-2757:
---
Ok, a validation would be great.
Hive
[
https://issues.apache.org/jira/browse/FLUME-2753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660597#comment-14660597
]
Ashish Paliwal commented on FLUME-2753:
---
+1
Running the tests before committing
[
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
[
https://issues.apache.org/jira/browse/FLUME-2660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14646791#comment-14646791
]
Ashish Paliwal commented on FLUME-2660:
---
[~jrufus] Fixed the build issue
[
https://issues.apache.org/jira/browse/FLUME-2660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14647004#comment-14647004
]
Ashish Paliwal commented on FLUME-2660:
---
The site is updated, already has this fix
[
https://issues.apache.org/jira/browse/FLUME-2746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639052#comment-14639052
]
Ashish Paliwal commented on FLUME-2746:
---
For #1 Download the source (not sure if you
[
https://issues.apache.org/jira/browse/FLUME-2660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639063#comment-14639063
]
Ashish Paliwal commented on FLUME-2660:
---
[~jrufus] Can you take a quick look
[
https://issues.apache.org/jira/browse/FLUME-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14617692#comment-14617692
]
Ashish Paliwal edited comment on FLUME-2632 at 7/8/15 12:02 AM
[
https://issues.apache.org/jira/browse/FLUME-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14617692#comment-14617692
]
Ashish Paliwal commented on FLUME-2632:
---
[~gwenshap] Can you have a look
[
https://issues.apache.org/jira/browse/FLUME-2713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14617814#comment-14617814
]
Ashish Paliwal commented on FLUME-2713:
---
[~hshreedharan] I committed on both trunk
[
https://issues.apache.org/jira/browse/FLUME-2713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14617900#comment-14617900
]
Ashish Paliwal commented on FLUME-2713:
---
Thanks [~jrufus] Shall take care next time
[
https://issues.apache.org/jira/browse/FLUME-2713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14617807#comment-14617807
]
Ashish Paliwal commented on FLUME-2713:
---
Sure, missed that part.
+1 committing
[
https://issues.apache.org/jira/browse/FLUME-2672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14617453#comment-14617453
]
Ashish Paliwal commented on FLUME-2672:
---
Getting an error while applying the patch
[
https://issues.apache.org/jira/browse/FLUME-2736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14615357#comment-14615357
]
Ashish Paliwal commented on FLUME-2736:
---
HTTP Source is not a pull source, you need
[
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
[
https://issues.apache.org/jira/browse/FLUME-2672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14615981#comment-14615981
]
Ashish Paliwal commented on FLUME-2672:
---
Let me check and commit.
NPE
[
https://issues.apache.org/jira/browse/FLUME-2736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14614464#comment-14614464
]
Ashish Paliwal commented on FLUME-2736:
---
Not sure what are you trying to achieve
[
https://issues.apache.org/jira/browse/FLUME-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14614015#comment-14614015
]
Ashish Paliwal commented on FLUME-2730:
---
There is nothing in configuration
[
https://issues.apache.org/jira/browse/FLUME-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14601601#comment-14601601
]
Ashish Paliwal commented on FLUME-2729:
---
I didn't look much into the patch, but I
[
https://issues.apache.org/jira/browse/FLUME-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14602212#comment-14602212
]
Ashish Paliwal commented on FLUME-2729:
---
It's just a suggestion :) I know Guava
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
new features.
Congratulations and Welcome, Johny!
Cheers,
Hari Shreedharan
--
thanks
ashish
Blog: http://www.ashishpaliwal.com/blog
My Photo Galleries: http://www.pbase.com/ashishpaliwal
[
https://issues.apache.org/jira/browse/FLUME-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14588785#comment-14588785
]
Ashish Paliwal commented on FLUME-2720:
---
IMHO we should have atleast some basic
/
The tag to be voted on:
https://git-wip-us.apache.org/repos/asf?p=flume.git;a=commit;h=f7560038a25430378f09ea631b6e472979d7988c
Flume's KEYS file containing PGP keys we use to sign the release:
http://www.apache.org/dist/flume/KEYS
Thanks,
Rufus
--
thanks
ashish
Blog: http
at this point.
Comments?
Thanks,
Hari Shreedharan
--
thanks
ashish
Blog: http://www.ashishpaliwal.com/blog
My Photo Galleries: http://www.pbase.com/ashishpaliwal
Thanks Otis and Gwen !
On Tue, May 12, 2015 at 11:49 AM, Gwen Shapira gshap...@cloudera.com wrote:
Congrats Ashish and thanks for all the reviews :)
On Fri, May 8, 2015 at 8:42 PM, Hari Shreedharan hshreedha...@apache.org
wrote:
On behalf of the Apache Flume PMC, I am excited to welcome
to be voted on:
https://git-wip-us.apache.org/repos/asf?p=flume.git;a=tag;h=24ae0e7409f057667a9756ec3d7d494a58d8ed1d
Flume's KEYS file containing PGP keys we use to sign the release:
http://www.apache.org/dist/flume/KEYS
Thanks,
Rufus
--
thanks
ashish
Blog: http
by return email, and delete all copies
of this message.
On Fri, May 8, 2015 at 2:29 PM, Roshan Naik ros...@hortonworks.com wrote:
Congratulations Ashish !
From: Hari Shreedharan hshreedha...@apache.org
Reply-To: u...@flume.apache.org u...@flume.apache.org
Date: Friday, May 8, 2015 10:42 AM
)
at org.apache.derby.impl.services.monitor.BaseMonitor.bootService(Unknown
Source)
at
org.apache.derby.impl.services.monitor.BaseMonitor.createPersistentService(Unknown
Source)
at
org.apache.derby.iapi.services.monitor.Monitor.createPersistentService(Unknown
Source)
... 38 more
On Sat, May 2, 2015 at 8:26 AM, Ashish paliwalash...@gmail.com wrote
against Java 8. I think there are several
jiras open to fix Flume to work properly against Java 8, though I don't
think all of them have any work on it yet. Can you test against Java 7?
On Thu, Apr 30, 2015 at 5:11 AM, Ashish paliwalash...@gmail.com wrote:
Have trouble with the build. I don't
I am seeing a lot of email with fix version being updated from 1.5.1
to 1.6.0, like https://issues.apache.org/jira/browse/FLUME-2251
I believe this went into 1.5.1.
Just curious on how JIRA's version update is to be done for a release
(for my benefit)
thanks
ashish
Thanks Johny !
Got it.
Somehow I had a feeling that Kafka stuff went into a release. Might be
some race condition in my head :)
thanks
ashish
On Fri, Apr 17, 2015 at 10:18 PM, Johny Rufus jru...@cloudera.com wrote:
Hi Ashish,
FLUME-2251 is not in 1.5.1, if you look at the commits for tag
12, 2015 at 3:43 AM, 李响 wate...@gmail.com wrote:
Hi Johny and harry,
I think it is a must to include FLUME-2575
https://issues.apache.org/jira/browse/FLUME-2575. Do you agree ?
On Sat, Apr 11, 2015 at 11:21 AM, Ashish paliwalash...@gmail.com
wrote:
This jira FLUME-2632 - High CPU
[
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
[
https://issues.apache.org/jira/browse/FLUME-2672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14496248#comment-14496248
]
Ashish Paliwal commented on FLUME-2672:
---
+1, Patch looks good. May be we should have
This jira FLUME-2632 - High CPU on KafkaSink, might also be worth adding to 1.6
It's a simple fix.
On Tue, Apr 7, 2015 at 7:21 AM, Ashish paliwalash...@gmail.com wrote:
If I am not late for the party, here are some JIRA's needing some attention
FLUME-2613 - Tool/script for deleting individual
[
https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14486860#comment-14486860
]
Ashish Paliwal commented on FLUME-2437:
---
[~jrufus] Did you get time to update
[
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
it starts.
I have a test on it ,it can sink all the checked contents without lost.
thank you!
here is my github repo:
https://github.com/cwtree/flume-filemonitor-source
--
thanks
ashish
Blog: http://www.ashishpaliwal.com/blog
My Photo Galleries: http://www.pbase.com/ashishpaliwal
and disk writes) are almost same. What can be
reason for this strange behavior ??
Thanks
Ajeet
--
AJEET PRATAP SINGH
--
thanks
ashish
Blog: http://www.ashishpaliwal.com/blog
My Photo Galleries: http://www.pbase.com/ashishpaliwal
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
Before the thread fades in-memory, here is the JIRA
https://issues.apache.org/jira/browse/FLUME-2661
On Thu, Apr 2, 2015 at 6:26 AM, Ashish paliwalash...@gmail.com wrote:
Is it possible to share the method and class name? It would be
somewhere in client package I guess.
I shall do the rest
Shreedharan
hshreedha...@cloudera.com
wrote:
I am all in for including it, but it looks like it is Java 7+ - so we
have
to wait for Flume 1.7 to actually do it, since 1.6 will be the last
release
we will be supporting Java 6. I am ok with doing a 1.7 release right
after.
--
thanks
ashish
Blog
[
https://issues.apache.org/jira/browse/FLUME-2655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14482603#comment-14482603
]
Ashish Paliwal commented on FLUME-2655:
---
IMHO, this is the correct behaviour, unless
[
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
).
Thanks, Hari
On Tue, Mar 31, 2015 at 9:27 AM, Ashish paliwalash...@gmail.com wrote:
Does ELB provide any kind of status code when it rejects the request
or it just doesn't send any response?
Perhaps adding a JIRA would be great. Doesn't ELB times out connection
which are Idle for more
Does ELB provide any kind of status code when it rejects the request
or it just doesn't send any response?
Perhaps adding a JIRA would be great. Doesn't ELB times out connection
which are Idle for more than 60 sec?
thanks
ashish
On Tue, Mar 31, 2015 at 7:50 PM, Otis Gospodnetic
otis.gospodne
back, I can fork Johny repo
and send PR's with changes.
There are lot of JIRA's with patch available status, let's scan them
and see if we can push in the changes.
thanks
ashish
On Tue, Mar 31, 2015 at 5:52 AM, Hari Shreedharan
hshreedha...@cloudera.com wrote:
Flume devs,
I am going
Hi Otis,
S3 Source is on my priority list. I shall spend some time with it as
soon as I am back from vacation.
thanks
ashish
On Mon, Mar 30, 2015 at 9:32 AM, Otis Gospodnetic
otis.gospodne...@gmail.com wrote:
Hi Ashish,
I think there is that S3 Source JIRA that's waiting for review love
Not to push on the release. Please take your time.
ML was so silent, it was killing me :)
On Thu, Mar 19, 2015 at 11:51 PM, Johny Rufus jru...@cloudera.com wrote:
Hari/Ashish,
We can begin the release work starting from Monday.
Thanks,
Rufus
On Thu, Mar 19, 2015 at 11:16 AM, Hari
[
https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14363305#comment-14363305
]
Ashish Paliwal commented on FLUME-2613:
---
Handling for command line parameters added
[
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
[
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: FLUME
[
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
[
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
-
Key
[
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
/flume/source/s3/S3ObjectEventReader.java
https://reviews.apache.org/r/31643/#comment124039
Do we still need this? Should't it be abstracted with MetadataStore
- Ashish Paliwal
On March 2, 2015, 10:26 p.m., Johny Rufus John wrote
[
https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14362276#comment-14362276
]
Ashish Paliwal commented on FLUME-2437:
---
Published a few review comments, would need
[
https://issues.apache.org/jira/browse/FLUME-2636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14362249#comment-14362249
]
Ashish Paliwal commented on FLUME-2636:
---
ok found it https://issues.apache.org/jira
/apache/flume/sink/kafka/TestKafkaSink.java
80f764f
Diff: https://reviews.apache.org/r/32084/diff/
Testing
---
Modified testEmptyChannel as per new condition
Thanks,
Ashish Paliwal
[
https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14362702#comment-14362702
]
Ashish Paliwal commented on FLUME-2613:
---
Writing in customized format was in context
. Better to add one more
metric for total channel events.
- Ashish
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/31932/#review76491
[
https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14362209#comment-14362209
]
Ashish Paliwal commented on FLUME-2613:
---
Just a wild thought, The Event Validator
[
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
Cases Added
Thanks,
Ashish Paliwal
[
https://issues.apache.org/jira/browse/FLUME-2636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14362224#comment-14362224
]
Ashish Paliwal commented on FLUME-2636:
---
https://issues.apache.org/jira/browse/FLUME
[
https://issues.apache.org/jira/browse/FLUME-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14362226#comment-14362226
]
Ashish Paliwal commented on FLUME-2437:
---
I did had a cursory look
/
Testing
---
Test Cases Added
Thanks,
Ashish Paliwal
[
https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14361637#comment-14361637
]
Ashish Paliwal commented on FLUME-2613:
---
Updated as per comment. Now the tool
[
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
[
https://issues.apache.org/jira/browse/FLUME-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14360101#comment-14360101
]
Ashish Paliwal commented on FLUME-2613:
---
Yup. The code shall be simple. Check would
1 - 100 of 840 matches
Mail list logo
