Messages by Thread
-
-
[jira] [Created] (FLUME-3092) Extend the FileChannel's monitoring metrics
Denes Arvay (JIRA)
-
[jira] [Created] (FLUME-3091) Swift Source
Ping Wang (JIRA)
-
[GitHub] flume pull request #130: when the file is rename, it's pos becomes to 0,and ...
leocook
-
[jira] [Created] (FLUME-3090) cassandra sink
Kangping Lu (JIRA)
-
[jira] [Comment Edited] (FLUME-3040) Flume client can not append events batch, deflate compression is failing
prayagupd (JIRA)
-
[jira] [Commented] (FLUME-3040) Flume client can not append events batch, deflate compression is failing
chenchunbin (JIRA)
-
[jira] [Updated] (FLUME-3085) HDFS Sink can skip flushing some BucketWriters, might lead to data loss
Mike Percy (JIRA)
-
[jira] [Resolved] (FLUME-3085) HDFS Sink can skip flushing some BucketWriters, might lead to data loss
Mike Percy (JIRA)
-
[jira] [Updated] (FLUME-3089) flume hive sink
mengge zhang (JIRA)
-
[jira] [Created] (FLUME-3089) flume hive sink
mengge zhang (JIRA)
-
Build failed in Jenkins: Flume-trunk-hbase-1 #246
Apache Jenkins Server
-
[jira] [Resolved] (FLUME-3083) Taildir source can miss events if file updated in same second as file close
JIRA
-
[jira] [Commented] (FLUME-3083) Taildir source can miss events if file updated in same second as file close
JIRA
-
[jira] [Created] (FLUME-3088) Flume channel failed to initialize log replay
sri kalyan kasyap vundrakonda (JIRA)
-
[jira] [Reopened] (FLUME-3033) Add SSL support to JMS source
Marcell Hegedus (JIRA)
-
[jira] [Commented] (FLUME-3087) Change log level from WARN to INFO when using default "maxIOWorkers" value.
Denes Arvay (JIRA)
-
[jira] [Updated] (FLUME-3087) Change log level from WARN to INFO when using default "maxIOWorkers" value.
Takafumi Saito (JIRA)
-
[jira] [Created] (FLUME-3087) Change log level from WARN to INFO when using default "maxIOWorkers" value.
Takafumi Saito (JIRA)
-
[GitHub] flume pull request #129: FLUME-3085: HDFS Sink can skip flushing some Bucket...
adenes
-
[jira] [Commented] (FLUME-3085) HDFS Sink can skip flushing some BucketWriters, might lead to data loss
ASF GitHub Bot (JIRA)
-
[jira] [Updated] (FLUME-2906) decrease GC overhead in SimpleEvent
Miroslav Holubec (JIRA)
-
[jira] [Updated] (FLUME-3083) Taildir source can miss events if file updated in same second as file close
eskrm (JIRA)
-
Review Request 58470: FLUME-3084 : HDFS Sink - Provide ability to roll the file with custom conditions.
Kallam Reddy
-
[jira] [Updated] (FLUME-3084) HDFS Sink - Provide ability to roll the file beyond interval, size and count.
Kallam Reddy (JIRA)
-
[jira] [Commented] (FLUME-3086) KafkaChannel commits consume offset to Zookeeper every time causing performance problem
Jeff Holoman (JIRA)
-
[jira] [Created] (FLUME-3086) KafkaChannel commits consume offset to Zookeeper every time causing performance problem
JiYeon OH (JIRA)
-
[jira] [Created] (FLUME-3085) HDFS Sink can skip flushing some BucketWriters, might lead to data loss
Denes Arvay (JIRA)
-
Interceptor or custom sink?
Felipe Dino
-
[jira] [Created] (FLUME-3084) HDFS Sink - Provide ability to roll the file beyond interval, size and count.
Kallam Reddy (JIRA)
-
[jira] [Commented] (FLUME-1302) FileChannel Log error message when there is no write permission
Umesh Chaudhary (JIRA)
-
[GitHub] flume pull request #128: FLUME-3083. Change file update condition in Taildir...
eskrm
-
[jira] [Resolved] (FLUME-2817) Sink for multi-agent flow example in user guide is set up incorrectly
JIRA
-
[jira] [Commented] (FLUME-3083) Taildir source can miss events if last updated time in same second as file mtime
Satoshi Iijima (JIRA)
-
[jira] [Resolved] (FLUME-3074) format error happened on windows when kafka sink is used
zhiqiangzhao (JIRA)
-
[jira] [Updated] (FLUME-3083) Taildir source can miss events if last updated time in same second as file mtime
eskrm (JIRA)
-
[jira] [Created] (FLUME-3083) Taildir source can miss events if last updated time in same second as file mtime
Eric (JIRA)
-
[jira] [Commented] (FLUME-3054) hflushOrSync method in HDFS Sink should not treat ClosedChannelException as an error
majid (JIRA)
-
Pending pull requests
Denes Arvay
-
[jira] [Updated] (FLUME-3082) JVM hang?I extended the functionality of tailDIrSource,but sometimes flume process hang,i do not down know why
lancerlin (JIRA)
-
[jira] [Created] (FLUME-3082) I extended the functionality of tailDIrSource,but sometimes flume process hang,i do not down know why
lancerlin (JIRA)
-
[jira] [Updated] (FLUME-3081) KafkaSource outputs offset in header
Viktor Gerdin (JIRA)
-
[jira] [Created] (FLUME-3081) KafkaSource outputs offset in header
Viktor Gerdin (JIRA)
-
[jira] [Commented] (FLUME-2477) Flume file channel fails when the source file is larger than 64MB
Dineshraja (JIRA)
-
[GitHub] flume pull request #127: FLUME-3080. Call DistributedFileSystem.recoverLease...
adenes
-
[jira] [Commented] (FLUME-3080) Close failure in HDFS Sink might cause data loss
ASF GitHub Bot (JIRA)
-
[jira] [Commented] (FLUME-3036) Create a RegexSerializer for Hive Sink
Kalyan (JIRA)
-
[jira] [Updated] (FLUME-3080) Close failure in HDFS Sink might cause data loss
Denes Arvay (JIRA)
-
[jira] [Created] (FLUME-3080) Close failure in HDFS Sink might cause data loss
Denes Arvay (JIRA)
-
[jira] [Commented] (FLUME-3074) format error happened on windows when kafka sink is used
Jinjiang Ling (JIRA)
-
[jira] [Assigned] (FLUME-2817) Sink for multi-agent flow example in user guide is set up incorrectly
Marcell Hegedus (JIRA)
-
[GitHub] flume pull request #126: FLUME-2817. Sink for multi-agent flow example in us...
marcellhegedus
-
[jira] [Commented] (FLUME-2817) Sink for multi-agent flow example in user guide is set up incorrectly
ASF GitHub Bot (JIRA)
-
[jira] [Commented] (FLUME-2451) HDFS Sink Cannot Reconnect After NameNode Restart
Piotr Wiecek (JIRA)
-
[jira] [Closed] (FLUME-2860) Typo in flume documentation - List item in Kafka channel not formatted properly in rst
Marcell Hegedus (JIRA)
-
[jira] [Updated] (FLUME-2860) Typo in flume documentation - List item in Kafka channel not formatted properly in rst
Marcell Hegedus (JIRA)
-
[GitHub] flume pull request #125: bugfix: when loglevel is debug, Kafka Sink will thr...
loleek
-
[jira] [Commented] (FLUME-3043) KafkaSink SinkCallback throws NullPointerException when Log4J level is debug
ASF GitHub Bot (JIRA)
-
[jira] [Created] (FLUME-3079) HDFS sink using snappy compression cannot process .tmp file correctly when data is writing in
Chang Zong (JIRA)
-
[jira] [Commented] (FLUME-2545) How to convert *.bz2.tmp to *.bz2 file after restating the instance
Chang Zong (JIRA)
-
[jira] [Created] (FLUME-3078) Expose Monitoring Metrics For Netcat Source
Gangaraju (JIRA)
-
Writing custom metrics service to send flume metric data to a outside running application
Naveenkumar
-
[jira] [Comment Edited] (FLUME-1702) HDFSEventSink should write to a hidden file as opposed to a .tmp file
darkz (JIRA)
-
[jira] [Commented] (FLUME-1702) HDFSEventSink should write to a hidden file as opposed to a .tmp file
darkz (JIRA)
-
[jira] [Updated] (FLUME-3077) Unexpected exception from downstream with Avro sink+source compression (deflate)
Kai (JIRA)
-
[jira] [Created] (FLUME-3077) Unexpected exception from downstream with Avro sink+source compression (deflate)
DuLe (JIRA)
-
The correction of the bug: 3021: flume Elasticsearch 5.0 not support
Sabrine Fatnassi
-
[GitHub] flume pull request #124: FLUME-199 Remove hardcoded ports from unit tests
andrasbeni
-
[jira] [Commented] (FLUME-199) Unit tests should hunt for available ports if defaults are in use
ASF GitHub Bot (JIRA)
-
[jira] [Commented] (FLUME-2794) Flume 1.6 HBase 1.12 java.lang.NoSuchMethodError: org.apache.hadoop.hbase.client.Put.setWriteToWAL(Z)V
Andrei (JIRA)
-
[jira] [Commented] (FLUME-3076) property flumeBatchSize in kafka sink confused
Jeff Holoman (JIRA)
-
[jira] [Assigned] (FLUME-3076) property flumeBatchSize in kafka sink confused
Jeff Holoman (JIRA)
-
[jira] [Created] (FLUME-3076) property flumeBatchSize in kafka sink confused
Kamil June (JIRA)
-
[jira] [Updated] (FLUME-3074) format error happened on windows when kafka sink is used
zhiqiangzhao (JIRA)
-
[GitHub] flume pull request #123: Added support for Filter Queries read from config f...
scottkp
-
[jira] [Created] (FLUME-3075) TestKafkaSink.testStaticTopic UT fails with NPE
Yesha Vora (JIRA)
-
[jira] [Commented] (FLUME-2293) Isolate Flume agent plugins to their own classloader
Kanstantsin Kamkou (JIRA)
-
[GitHub] flume pull request #122: Flume 1.7
skillax
-
[jira] [Created] (FLUME-3074) format error happened on windows when kafka sink is used
zhiqiangzhao (JIRA)
-
[jira] [Comment Edited] (FLUME-3021) flume Elasticsearch 5.0 not support
Yonghao Zou (JIRA)
-
[jira] [Updated] (FLUME-2293) Isolate Flume agent plugins to their own classloader
Mike Percy (JIRA)
-
Review Request 57617: FLUME-2620 File Channel to support empty values in headers
Marcell Hegedus
-
Review Request 57676: FLUME-3057 Build fails due to unsupported snappy-java version on ppc64le
Pravin Dsilva
-
[jira] [Updated] (FLUME-3073) KafkaSource EXCEPTION java.lang.IllegalStateException: Correlation id for response (1077833) does not match request (1077776)
xuwei (JIRA)
-
[jira] [Created] (FLUME-3073) KafkaSource EXCEPTION java.lang.IllegalStateException: Correlation id for response (1077833) does not match request (1077776)
xuwei (JIRA)
-
[GitHub] flume pull request #121: FLUME-3072 Add IP address to headers in flume log4j...
andrasbeni
-
[jira] [Commented] (FLUME-3072) Add IP address to headers in flume log4j appender
ASF GitHub Bot (JIRA)
-
[jira] [Assigned] (FLUME-2620) File channel throws NullPointerException if a header value is null
Marcell Hegedus (JIRA)
-
[jira] [Created] (FLUME-3072) Add IP address to headers in flume log4j appender
Andras Beni (JIRA)
-
[GitHub] flume pull request #120: FLUME-2579 Support durable subscription in JMSSourc...
andrasbeni
-
[jira] [Commented] (FLUME-2579) JMS source support durable subscriptions and message listening
ASF GitHub Bot (JIRA)
-
[jira] [Assigned] (FLUME-2579) JMS source support durable subscriptions and message listening
Andras Beni (JIRA)
-
[jira] [Commented] (FLUME-3001) Flume Twitter data Streaming issue
Andy Piper (JIRA)
-
[jira] [Updated] (FLUME-2960) Support Wildcards in directory name in TaildirSource
tinawenqiao (JIRA)
-
Review Request 57538: FLUME-3021 flume Elasticsearch 5.0 not support
Yonghao Zou
-
[jira] [Updated] (FLUME-3021) flume Elasticsearch 5.0 not support
Yonghao Zou (JIRA)