[jira] [Created] (FLUME-3051) Mention the incompatibility of Kafka source with 0.8.x Kafka brokers

Umesh Chaudhary created FLUME-3051: -- Summary: Mention the incompatibility of Kafka source with 0.8.x Kafka brokers Key: FLUME-3051 URL: https://issues.apache.org/jira/browse/FLUME-3051 Project:

[jira] [Commented] (FLUME-1798) Avro source can't bind to wildcard address. Problem with ipv6

[ https://issues.apache.org/jira/browse/FLUME-1798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15853105#comment-15853105 ] Umesh Chaudhary commented on FLUME-1798: One more observation regarding this issue. On Ubuntu

[jira] [Commented] (FLUME-3052) Getting heap space error even changing the memory channel to file channel

[ https://issues.apache.org/jira/browse/FLUME-3052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15853420#comment-15853420 ] Umesh Chaudhary commented on FLUME-3052: Hi [~sriramk], Can you attach full stack trace of the

[jira] [Commented] (FLUME-2811) Taildir source doesn't call stop() on graceful shutdown

[ https://issues.apache.org/jira/browse/FLUME-2811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15483206#comment-15483206 ] Umesh Chaudhary commented on FLUME-2811: Hello [~siefried12] [~liorze] , I can work for this. >

[jira] [Commented] (FLUME-2692) Make the number of threads in AsyncHbaseSink configurable

[ https://issues.apache.org/jira/browse/FLUME-2692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15483188#comment-15483188 ] Umesh Chaudhary commented on FLUME-2692: Hello [~jrufus], Are you still working on this? If not, I

[jira] [Commented] (FLUME-2647) File Channel must print the reason for the channel being closed in channelClosed checks

[ https://issues.apache.org/jira/browse/FLUME-2647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15483864#comment-15483864 ] Umesh Chaudhary commented on FLUME-2647: Hello [~jrufus], If you want I can work on this. > File

[jira] [Commented] (FLUME-2883) LoadBalancingRpcClient returns wrong value for batchSize

[ https://issues.apache.org/jira/browse/FLUME-2883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15483941#comment-15483941 ] Umesh Chaudhary commented on FLUME-2883: [~agnek], I am sorry but I don't see any getBatchSize

[jira] [Comment Edited] (FLUME-2647) File Channel must print the reason for the channel being closed in channelClosed checks

[ https://issues.apache.org/jira/browse/FLUME-2647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15518851#comment-15518851 ] Umesh Chaudhary edited comment on FLUME-2647 at 9/24/16 10:44 AM: -- Hi

[jira] [Commented] (FLUME-2647) File Channel must print the reason for the channel being closed in channelClosed checks

[ https://issues.apache.org/jira/browse/FLUME-2647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15518851#comment-15518851 ] Umesh Chaudhary commented on FLUME-2647: Hi @bessbd, Sure, will submit the updated patch soon. >

[jira] [Updated] (FLUME-2647) File Channel must print the reason for the channel being closed in channelClosed checks

[ https://issues.apache.org/jira/browse/FLUME-2647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary updated FLUME-2647: --- Attachment: (was: FLUME-2647-0.patch) > File Channel must print the reason for the

[jira] [Commented] (FLUME-2583) Flafka unit tests should randomize ports

[ https://issues.apache.org/jira/browse/FLUME-2583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535035#comment-15535035 ] Umesh Chaudhary commented on FLUME-2583: Hi [~gwenshap] , would it be fine if I take this one?

[jira] [Commented] (FLUME-2623) Test testRemoveFields(org.apache.flume.source.TestSyslogUdpSource) fails randomly

[ https://issues.apache.org/jira/browse/FLUME-2623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535027#comment-15535027 ] Umesh Chaudhary commented on FLUME-2623: Hi [~hshreedharan] [~jholoman] [~bessbd] Would it be fine

[jira] [Commented] (FLUME-2883) LoadBalancingRpcClient returns wrong value for batchSize

[ https://issues.apache.org/jira/browse/FLUME-2883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535071#comment-15535071 ] Umesh Chaudhary commented on FLUME-2883: Hi [~agnek], Apologies as I assign this to me without

[jira] [Commented] (FLUME-2811) Taildir source doesn't call stop() on graceful shutdown

[ https://issues.apache.org/jira/browse/FLUME-2811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535050#comment-15535050 ] Umesh Chaudhary commented on FLUME-2811: Hello [~siefried12], [~liorze] IMHO InterruptedException

[jira] [Commented] (FLUME-2623) Test testRemoveFields(org.apache.flume.source.TestSyslogUdpSource) fails randomly

[ https://issues.apache.org/jira/browse/FLUME-2623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535448#comment-15535448 ] Umesh Chaudhary commented on FLUME-2623: Thanks [~bessbd]. I will take it start working on this.

[jira] [Comment Edited] (FLUME-2623) Test testRemoveFields(org.apache.flume.source.TestSyslogUdpSource) fails randomly

[ https://issues.apache.org/jira/browse/FLUME-2623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535448#comment-15535448 ] Umesh Chaudhary edited comment on FLUME-2623 at 9/30/16 8:49 AM: - Thanks

[jira] [Updated] (FLUME-2989) Kafka Channel metrics missing eventTakeAttemptCount and eventPutAttemptCount

[ https://issues.apache.org/jira/browse/FLUME-2989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary updated FLUME-2989: --- Attachment: FLUME-2989-0.patch > Kafka Channel metrics missing eventTakeAttemptCount and

[jira] [Assigned] (FLUME-2980) Automated concurrent Kafka offset migration test

[ https://issues.apache.org/jira/browse/FLUME-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary reassigned FLUME-2980: -- Assignee: Umesh Chaudhary > Automated concurrent Kafka offset migration test >

[jira] [Commented] (FLUME-2883) LoadBalancingRpcClient returns wrong value for batchSize

[ https://issues.apache.org/jira/browse/FLUME-2883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15503623#comment-15503623 ] Umesh Chaudhary commented on FLUME-2883: Yes, that is a valid point. [~mpercy], please provide

[jira] [Assigned] (FLUME-2647) File Channel must print the reason for the channel being closed in channelClosed checks

[ https://issues.apache.org/jira/browse/FLUME-2647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary reassigned FLUME-2647: -- Assignee: Umesh Chaudhary (was: Johny Rufus) > File Channel must print the reason for

[jira] [Commented] (FLUME-2647) File Channel must print the reason for the channel being closed in channelClosed checks

[ https://issues.apache.org/jira/browse/FLUME-2647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15516300#comment-15516300 ] Umesh Chaudhary commented on FLUME-2647: Hi [~bessbd] [~jholoman] , I have submitted a review

[jira] [Updated] (FLUME-2647) File Channel must print the reason for the channel being closed in channelClosed checks

[ https://issues.apache.org/jira/browse/FLUME-2647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary updated FLUME-2647: --- Attachment: FLUME-2647-0.patch > File Channel must print the reason for the channel being

[jira] [Commented] (FLUME-2647) File Channel must print the reason for the channel being closed in channelClosed checks

[ https://issues.apache.org/jira/browse/FLUME-2647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512368#comment-15512368 ] Umesh Chaudhary commented on FLUME-2647: Thanks [~jholoman], I will start to work on this. May I

[jira] [Commented] (FLUME-2647) File Channel must print the reason for the channel being closed in channelClosed checks

[ https://issues.apache.org/jira/browse/FLUME-2647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15513040#comment-15513040 ] Umesh Chaudhary commented on FLUME-2647: Hi [~bessbd], actually my email ID is

[jira] [Assigned] (FLUME-2883) LoadBalancingRpcClient returns wrong value for batchSize

[ https://issues.apache.org/jira/browse/FLUME-2883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary reassigned FLUME-2883: -- Assignee: Umesh Chaudhary > LoadBalancingRpcClient returns wrong value for batchSize >

[jira] [Commented] (FLUME-2894) Flume components should stop in the correct order (graceful shutdown)

[ https://issues.apache.org/jira/browse/FLUME-2894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15529354#comment-15529354 ] Umesh Chaudhary commented on FLUME-2894: Wondering if we can achieve this by current data

[jira] [Commented] (FLUME-2795) Sinks with hdfs path with escape sequence do not close current .tmp file when changit to new directory

[ https://issues.apache.org/jira/browse/FLUME-2795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15528863#comment-15528863 ] Umesh Chaudhary commented on FLUME-2795: Hi [~dscarlat], do you still see this issue? If so, would

[jira] [Commented] (FLUME-2980) Automated concurrent Kafka offset migration test

[ https://issues.apache.org/jira/browse/FLUME-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15542519#comment-15542519 ] Umesh Chaudhary commented on FLUME-2980: Hi [~mpercy], I would like to work on this. > Automated

[jira] [Updated] (FLUME-2647) File Channel must print the reason for the channel being closed in channelClosed checks

[ https://issues.apache.org/jira/browse/FLUME-2647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary updated FLUME-2647: --- Attachment: FLUME-2647-3.patch > File Channel must print the reason for the channel being

[jira] [Assigned] (FLUME-2811) Taildir source doesn't call stop() on graceful shutdown

[ https://issues.apache.org/jira/browse/FLUME-2811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary reassigned FLUME-2811: -- Assignee: Umesh Chaudhary > Taildir source doesn't call stop() on graceful shutdown >

[jira] [Updated] (FLUME-2980) Automated concurrent Kafka offset migration test

[ https://issues.apache.org/jira/browse/FLUME-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary updated FLUME-2980: --- Attachment: FLUME-2980-0.patch > Automated concurrent Kafka offset migration test >

[jira] [Commented] (FLUME-2989) Kafka Channel metrics missing eventTakeAttemptCount and eventPutAttemptCount

[ https://issues.apache.org/jira/browse/FLUME-2989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15599327#comment-15599327 ] Umesh Chaudhary commented on FLUME-2989: @bessbd Thanks for reviewing the patch. I resubmitted one

[jira] [Assigned] (FLUME-3023) {variable} substitution doesn't work for property 'fileSuffix'

[ https://issues.apache.org/jira/browse/FLUME-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary reassigned FLUME-3023: -- Assignee: Umesh Chaudhary > {variable} substitution doesn't work for property

[jira] [Updated] (FLUME-2989) Kafka Channel metrics missing eventTakeAttemptCount and eventPutAttemptCount

[ https://issues.apache.org/jira/browse/FLUME-2989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary updated FLUME-2989: --- Attachment: FLUME-2989-1.patch > Kafka Channel metrics missing eventTakeAttemptCount and

[jira] [Commented] (FLUME-1302) FileChannel Log error message when there is no write permission

[ https://issues.apache.org/jira/browse/FLUME-1302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964079#comment-15964079 ] Umesh Chaudhary commented on FLUME-1302: [~mubarakseyed] after providing the dir path (for

[jira] [Updated] (FLUME-3203) Spooling dir source leaks records from a file when a corresponding .COMPLETED file already present

[ https://issues.apache.org/jira/browse/FLUME-3203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary updated FLUME-3203: --- Description: Here are the steps to reproduce: 1) Use below config in the flume agent:

[jira] [Updated] (FLUME-3203) Spooling dir source leaks records from a file when a corresponding .COMPLETED file already present

[ https://issues.apache.org/jira/browse/FLUME-3203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary updated FLUME-3203: --- Description: Here are the steps to reproduce: 1) Use below config in the flume agent:

[jira] [Created] (FLUME-3203) Spooling dir source leaks records from a file when a corresponding .COMPLETED file already present

Umesh Chaudhary created FLUME-3203: -- Summary: Spooling dir source leaks records from a file when a corresponding .COMPLETED file already present Key: FLUME-3203 URL: