[jira] [Commented] (FLUME-1796) Upgrade Thrift due to race condition in TThreadSeverPool

[ https://issues.apache.org/jira/browse/FLUME-1796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492967#comment-14492967 ] Hari Shreedharan commented on FLUME-1796: - [~venkatnrangan] - Sounds good. Can you

[jira] [Created] (FLUME-2668) Document SecureThriftRpcClient/SecureRpcClientFactory in Flume Developer Guide

Johny Rufus created FLUME-2668: -- Summary: Document SecureThriftRpcClient/SecureRpcClientFactory in Flume Developer Guide Key: FLUME-2668 URL: https://issues.apache.org/jira/browse/FLUME-2668 Project:

[jira] [Commented] (FLUME-2667) Add new Kafka Java API in flume-ng-kafka-sink which keep compatibility with current API

[ https://issues.apache.org/jira/browse/FLUME-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492953#comment-14492953 ] Hari Shreedharan commented on FLUME-2667: - [~gwenshap] - Could you please take a

[jira] [Commented] (FLUME-2646) Add JSON and CSV entity parsers to DatasetSink

[ https://issues.apache.org/jira/browse/FLUME-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492719#comment-14492719 ] Ryan Blue commented on FLUME-2646: -- bq. Should the parseHeader method use the configured

[jira] [Updated] (FLUME-2646) Add JSON and CSV entity parsers to DatasetSink

[ https://issues.apache.org/jira/browse/FLUME-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan Blue updated FLUME-2646: - Attachment: FLUME-2646.2.diff Fixed problems from Joey's review: * JSON and CSV parsers catch

[jira] [Updated] (FLUME-2619) Spooldir source does not log channel exceptions

[ https://issues.apache.org/jira/browse/FLUME-2619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johny Rufus updated FLUME-2619: --- Attachment: FLUME-2619.patch Nice catch, SpoolDir should specifically catch ChannelFullException

[jira] [Commented] (FLUME-2595) Add option to checkpoint on file channel shutdown

[ https://issues.apache.org/jira/browse/FLUME-2595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493171#comment-14493171 ] Hari Shreedharan commented on FLUME-2595: - TestFileChannelIntegrityTool.java Add

[jira] [Commented] (FLUME-2595) Add option to checkpoint on file channel shutdown

[ https://issues.apache.org/jira/browse/FLUME-2595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493133#comment-14493133 ] Hari Shreedharan commented on FLUME-2595: - Ah, so the issue is that the

[jira] [Updated] (FLUME-2619) Spooldir source does not log channel exceptions

[ https://issues.apache.org/jira/browse/FLUME-2619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johny Rufus updated FLUME-2619: --- Attachment: FLUME-2619-1.patch There is one more place in ChannelProcessor, where this should be

[jira] [Updated] (FLUME-2595) Add option to checkpoint on file channel shutdown

[ https://issues.apache.org/jira/browse/FLUME-2595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hari Shreedharan updated FLUME-2595: Attachment: FLUME-2595.v5.patch [~roshan_naik] - Please take a look at the change I made. I

Re: Fwd: Need help with Custom Flume Interceptors

Are you trying to write directly from the interceptor to HBase? Or are you using the HBase sinks? You can use mutliplexing channel selector to push to different sinks based on the content, with each sink writing to a different table/cf.  Thanks, Hari On Wed, Apr 8, 2015 at 8:54 PM,

[jira] [Commented] (FLUME-2595) Add option to checkpoint on file channel shutdown

[ https://issues.apache.org/jira/browse/FLUME-2595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493187#comment-14493187 ] Roshan Naik commented on FLUME-2595: Just took a look at it. Looks fine. please go

[jira] [Commented] (FLUME-2215) ResettableFileInputStream can't support ucs-4 character

[ https://issues.apache.org/jira/browse/FLUME-2215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493319#comment-14493319 ] Patrick Sodre commented on FLUME-2215: -- Jameel, Since there were two different

[jira] [Commented] (FLUME-2215) ResettableFileInputStream can't support ucs-4 character

[ https://issues.apache.org/jira/browse/FLUME-2215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493328#comment-14493328 ] Jameel Al-Aziz commented on FLUME-2215: --- [~sodre], your patch seems to be failing

[jira] [Commented] (FLUME-2595) Add option to checkpoint on file channel shutdown

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

[jira] [Updated] (FLUME-2595) Add option to checkpoint on file channel shutdown

[ https://issues.apache.org/jira/browse/FLUME-2595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hari Shreedharan updated FLUME-2595: Fix Version/s: v1.6.0 Add option to checkpoint on file channel shutdown

[jira] [Commented] (FLUME-2595) Add option to checkpoint on file channel shutdown

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

Jenkins build is still unstable: Flume-trunk-hbase-98 #88

See https://builds.apache.org/job/Flume-trunk-hbase-98/changes

[jira] [Commented] (FLUME-2595) Add option to checkpoint on file channel shutdown

[ https://issues.apache.org/jira/browse/FLUME-2595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493281#comment-14493281 ] Hudson commented on FLUME-2595: --- UNSTABLE: Integrated in Flume-trunk-hbase-98 #88 (See

[jira] [Updated] (FLUME-2668) Document SecureThriftRpcClient/SecureRpcClientFactory in Flume Developer Guide

[ https://issues.apache.org/jira/browse/FLUME-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johny Rufus updated FLUME-2668: --- Attachment: FLUME-2668.patch Attached patch, with documentation for SecureRpcClientFactory and usage

[jira] [Updated] (FLUME-2665) Update documentation for hdfs.closeTries based on FLUME-2586

[ https://issues.apache.org/jira/browse/FLUME-2665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johny Rufus updated FLUME-2665: --- Attachment: FLUME-2665.patch Attached patch, which reflects the documentation for the current

[jira] [Commented] (FLUME-2649) Elasticsearch sink doesn't handle JSON fields correctly

[ https://issues.apache.org/jira/browse/FLUME-2649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493507#comment-14493507 ] Jifeng Yin commented on FLUME-2649: --- This patch has something wrong for me. It turns

[jira] [Commented] (FLUME-2215) ResettableFileInputStream can't support ucs-4 character

[ https://issues.apache.org/jira/browse/FLUME-2215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492744#comment-14492744 ] Jameel Al-Aziz commented on FLUME-2215: --- Just wanted to mention that I've tried the

[jira] [Commented] (FLUME-2500) Add a channel that uses Kafka

[ https://issues.apache.org/jira/browse/FLUME-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492603#comment-14492603 ] Tao Li commented on FLUME-2500: --- I have a question about this issue. Flume support