Re: [jira] [Updated] (FLUME-2333) HTTP source handler doesn't allow for responses

Hi, Impeccable timing! I was going to submit a change very similar. I agree with you: I do think the HTTPSource ³simple handler has its place, because it provides a simple way to accept events via HTTP, but like you, I would like to have more flexibility in the API ­ so my custom handler can

Re: [jira] [Updated] (FLUME-2333) HTTP source handler doesn't allow for responses

I am not a committer, but I have no problem with additional changes to this report or patch item. It's true that the HTTP handler is limited in its openness for extension and if we can make a few changes to make it better, I'd be happy to look at any changes you make. The only thing that I'm

[jira] [Commented] (FLUME-1227) Introduce some sort of SpillableChannel

[ https://issues.apache.org/jira/browse/FLUME-1227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916097#comment-13916097 ] Hari Shreedharan commented on FLUME-1227: - [~roshan_naik] - When we roll 1.5,

[jira] [Created] (FLUME-2334) Upgrade Asynchbase to 1.5.0 as this include hbase 0.96.x support

Hari Shreedharan created FLUME-2334: --- Summary: Upgrade Asynchbase to 1.5.0 as this include hbase 0.96.x support Key: FLUME-2334 URL: https://issues.apache.org/jira/browse/FLUME-2334 Project: Flume

[jira] [Commented] (FLUME-2333) HTTP source handler doesn't allow for responses

[ https://issues.apache.org/jira/browse/FLUME-2333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916284#comment-13916284 ] Hari Shreedharan commented on FLUME-2333: - I like the idea of this jira, but I am

[jira] [Updated] (FLUME-2334) Upgrade Asynchbase to 1.5.0 as this include hbase 0.96.x support

[ https://issues.apache.org/jira/browse/FLUME-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hari Shreedharan updated FLUME-2334: Attachment: FLUME-2334.patch Just upgrading the version in pom.xml Upgrade Asynchbase to

[jira] [Commented] (FLUME-2333) HTTP source handler doesn't allow for responses

[ https://issues.apache.org/jira/browse/FLUME-2333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916340#comment-13916340 ] Jeremy Karlson commented on FLUME-2333: --- I understand your concerns. I did think

[jira] [Commented] (FLUME-2333) HTTP source handler doesn't allow for responses

[ https://issues.apache.org/jira/browse/FLUME-2333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916363#comment-13916363 ] Hari Shreedharan commented on FLUME-2333: - In this case, I am not talking about

Re: [jira] [Commented] (FLUME-2333) HTTP source handler doesn't allow for responses

What Hari proposed is very close to what I wrote. I didn¹t write a specific method to get the response on successful commit, but I like the idea, because I think it¹ll make the code more readable. In response to Hari¹s suggestion, I¹d just add the HttpRequest object as a parameter in the ³on

[jira] [Commented] (FLUME-2334) Upgrade Asynchbase to 1.5.0 as this include hbase 0.96.x support

[ https://issues.apache.org/jira/browse/FLUME-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916490#comment-13916490 ] ASF subversion and git services commented on FLUME-2334: Commit

[jira] [Commented] (FLUME-2324) Support writing to multiple HBase clusters using HBaseSink

[ https://issues.apache.org/jira/browse/FLUME-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916538#comment-13916538 ] Jarek Jarcec Cecho commented on FLUME-2324: --- Couple of nits: * I've noticed

[jira] [Commented] (FLUME-2328) FileChannel Dual Checkpoint Backup Thread not released on Application stop

[ https://issues.apache.org/jira/browse/FLUME-2328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916552#comment-13916552 ] Jarek Jarcec Cecho commented on FLUME-2328: --- +1 FileChannel Dual Checkpoint

[jira] [Commented] (FLUME-2328) FileChannel Dual Checkpoint Backup Thread not released on Application stop

[ https://issues.apache.org/jira/browse/FLUME-2328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916555#comment-13916555 ] ASF subversion and git services commented on FLUME-2328: Commit

[jira] [Commented] (FLUME-2328) FileChannel Dual Checkpoint Backup Thread not released on Application stop

[ https://issues.apache.org/jira/browse/FLUME-2328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916553#comment-13916553 ] ASF subversion and git services commented on FLUME-2328: Commit

[jira] [Commented] (FLUME-2323) Morphline sink must increment eventDrainAttemptCount when it takes event from channel

[ https://issues.apache.org/jira/browse/FLUME-2323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916580#comment-13916580 ] Jarek Jarcec Cecho commented on FLUME-2323: --- +1 Morphline sink must increment

[jira] [Commented] (FLUME-2323) Morphline sink must increment eventDrainAttemptCount when it takes event from channel

[ https://issues.apache.org/jira/browse/FLUME-2323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916582#comment-13916582 ] ASF subversion and git services commented on FLUME-2323: Commit

[jira] [Commented] (FLUME-2323) Morphline sink must increment eventDrainAttemptCount when it takes event from channel

[ https://issues.apache.org/jira/browse/FLUME-2323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916581#comment-13916581 ] ASF subversion and git services commented on FLUME-2323: Commit

[jira] [Commented] (FLUME-2283) Spool Dir source must check interrupt flag before writing to channel

[ https://issues.apache.org/jira/browse/FLUME-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916594#comment-13916594 ] ASF subversion and git services commented on FLUME-2283: Commit

[jira] [Resolved] (FLUME-2283) Spool Dir source must check interrupt flag before writing to channel

[ https://issues.apache.org/jira/browse/FLUME-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jarek Jarcec Cecho resolved FLUME-2283. --- Resolution: Fixed Fix Version/s: v1.5.0 Your contribution is appreciated

[jira] [Commented] (FLUME-2283) Spool Dir source must check interrupt flag before writing to channel

[ https://issues.apache.org/jira/browse/FLUME-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916592#comment-13916592 ] ASF subversion and git services commented on FLUME-2283: Commit

[jira] [Commented] (FLUME-2328) FileChannel Dual Checkpoint Backup Thread not released on Application stop

[ https://issues.apache.org/jira/browse/FLUME-2328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916602#comment-13916602 ] Hudson commented on FLUME-2328: --- SUCCESS: Integrated in flume-trunk #554 (See

[jira] [Commented] (FLUME-2334) Upgrade Asynchbase to 1.5.0 as this include hbase 0.96.x support

[ https://issues.apache.org/jira/browse/FLUME-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916601#comment-13916601 ] Hudson commented on FLUME-2334: --- SUCCESS: Integrated in flume-trunk #554 (See

[jira] [Commented] (FLUME-2324) Support writing to multiple HBase clusters using HBaseSink

[ https://issues.apache.org/jira/browse/FLUME-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916605#comment-13916605 ] Hari Shreedharan commented on FLUME-2324: - Thanks for the review, Jarcec. Will

[jira] [Updated] (FLUME-2324) Support writing to multiple HBase clusters using HBaseSink

[ https://issues.apache.org/jira/browse/FLUME-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hari Shreedharan updated FLUME-2324: Attachment: FLUME-2324-2.patch Support writing to multiple HBase clusters using HBaseSink

[jira] [Commented] (FLUME-2329) Add an alias for the Morphline Solr Sink

[ https://issues.apache.org/jira/browse/FLUME-2329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916610#comment-13916610 ] ASF subversion and git services commented on FLUME-2329: Commit

[jira] [Commented] (FLUME-2324) Support writing to multiple HBase clusters using HBaseSink

[ https://issues.apache.org/jira/browse/FLUME-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916632#comment-13916632 ] ASF subversion and git services commented on FLUME-2324: Commit

[jira] [Commented] (FLUME-2324) Support writing to multiple HBase clusters using HBaseSink

[ https://issues.apache.org/jira/browse/FLUME-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916631#comment-13916631 ] ASF subversion and git services commented on FLUME-2324: Commit

Build failed in Jenkins: flume-trunk #555

See https://builds.apache.org/job/flume-trunk/555/changes Changes: [jarcec] FLUME-2323: Morphline sink must increment eventDrainAttemptCount when it takes event from channel [jarcec] FLUME-2283: Spool Dir source must check interrupt flag before writing to channel

[jira] [Commented] (FLUME-2283) Spool Dir source must check interrupt flag before writing to channel

[ https://issues.apache.org/jira/browse/FLUME-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916659#comment-13916659 ] Hudson commented on FLUME-2283: --- FAILURE: Integrated in flume-trunk #555 (See

[jira] [Commented] (FLUME-2323) Morphline sink must increment eventDrainAttemptCount when it takes event from channel

[ https://issues.apache.org/jira/browse/FLUME-2323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916660#comment-13916660 ] Hudson commented on FLUME-2323: --- FAILURE: Integrated in flume-trunk #555 (See

Build failed in Jenkins: flume-trunk #556

See https://builds.apache.org/job/flume-trunk/556/changes Changes: [jarcec] FLUME-2329: Add an alias for the Morphline Solr Sink [jarcec] FLUME-2324: Support writing to multiple HBase clusters using HBaseSink -- [...truncated 544 lines...] [INFO]

[jira] [Commented] (FLUME-2324) Support writing to multiple HBase clusters using HBaseSink

[ https://issues.apache.org/jira/browse/FLUME-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916679#comment-13916679 ] Hudson commented on FLUME-2324: --- FAILURE: Integrated in flume-trunk #556 (See

[jira] [Created] (FLUME-2335) TestHBaseSink#testWithoutConfigurationObject() must delete the table at the end of the test

Hari Shreedharan created FLUME-2335: --- Summary: TestHBaseSink#testWithoutConfigurationObject() must delete the table at the end of the test Key: FLUME-2335 URL: https://issues.apache.org/jira/browse/FLUME-2335

[jira] [Updated] (FLUME-2335) TestHBaseSink#testWithoutConfigurationObject() must delete the table at the end of the test

[ https://issues.apache.org/jira/browse/FLUME-2335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hari Shreedharan updated FLUME-2335: Attachment: FLUME-2335.patch TestHBaseSink#testWithoutConfigurationObject() must delete

[jira] [Updated] (FLUME-2333) HTTP source handler doesn't allow for responses

[ https://issues.apache.org/jira/browse/FLUME-2333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabriel Commeau updated FLUME-2333: --- Attachment: FLUME-2333-2.diff So here is my contribution. I updated the javadoc, but not the

[jira] [Updated] (FLUME-2335) TestHBaseSink#testWithoutConfigurationObject() must delete the table at the end of the test

[ https://issues.apache.org/jira/browse/FLUME-2335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hari Shreedharan updated FLUME-2335: Attachment: FLUME-2335-1.patch TestHBaseSink#testWithoutConfigurationObject() must delete

[jira] [Commented] (FLUME-2335) TestHBaseSink#testWithoutConfigurationObject() must delete the table at the end of the test

[ https://issues.apache.org/jira/browse/FLUME-2335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13916974#comment-13916974 ] Hari Shreedharan commented on FLUME-2335: - Since the HBase sink modifies the