flume-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hudson (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLUME-3246) Validate flume configuration to prevent larger source batch size than the channel transaction capacity
Date Fri, 31 Aug 2018 03:55:00 GMT

    [ https://issues.apache.org/jira/browse/FLUME-3246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16598203#comment-16598203
] 

Hudson commented on FLUME-3246:
-------------------------------

SUCCESS: Integrated in Jenkins build Flume-trunk-hbase-1 #354 (See [https://builds.apache.org/job/Flume-trunk-hbase-1/354/])
FLUME-3246 Validate flume configuration to prevent larger source (szaboferee: [http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=dad828acbe40b218dc9c5bc741f5a6c7fa8b338f])
* (edit) flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FileChannel.java
* (edit) flume-ng-node/src/test/java/org/apache/flume/node/TestAbstractConfigurationProvider.java
* (edit) flume-ng-sdk/src/main/java/org/apache/flume/api/NettyAvroRpcClient.java
* (edit) flume-ng-sinks/flume-ng-hbase2-sink/src/main/java/org/apache/flume/sink/hbase2/HBase2Sink.java
* (edit) flume-ng-core/src/main/java/org/apache/flume/source/MultiportSyslogTCPSource.java
* (edit) flume-ng-core/src/test/java/org/apache/flume/sink/TestRollingFileSink.java
* (edit) flume-ng-node/src/main/java/org/apache/flume/node/AbstractConfigurationProvider.java
* (edit) flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySource.java
* (edit) flume-ng-sdk/src/main/java/org/apache/flume/api/ThriftRpcClient.java
* (edit) flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/DatasetSink.java
* (edit) flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java
* (edit) flume-ng-sdk/src/main/java/org/apache/flume/api/AbstractRpcClient.java
* (edit) flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/AsyncHBaseSink.java
* (add) flume-ng-core/src/main/java/org/apache/flume/conf/TransactionCapacitySupported.java
* (edit) flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSink.java
* (edit) flume-ng-core/src/main/java/org/apache/flume/sink/AbstractRpcSink.java
* (edit) flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/TaildirSource.java
* (edit) flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java
* (add) flume-ng-tests/src/test/java/org/apache/flume/test/agent/TestConfig.java
* (edit) flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveSink.java
* (edit) flume-ng-core/src/main/java/org/apache/flume/source/ExecSource.java
* (edit) flume-ng-sdk/src/main/java/org/apache/flume/api/FailoverRpcClient.java
* (edit) flume-ng-doc/sphinx/FlumeUserGuide.rst
* (edit) flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HBaseSink.java
* (add) flume-ng-core/src/main/java/org/apache/flume/conf/BatchSizeSupported.java
* (edit) flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineSink.java
* (edit) flume-ng-core/src/main/java/org/apache/flume/sink/NullSink.java
* (edit) flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java
* (edit) flume-ng-core/src/main/java/org/apache/flume/source/StressSource.java
* (delete) flume-ng-tests/src/test/java/org/apache/flume/test/agent/TestConfigFilters.java
* (edit) flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java
* (edit) flume-ng-sources/flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java
* (edit) flume-ng-sdk/src/main/java/org/apache/flume/api/LoadBalancingRpcClient.java
* (edit) flume-ng-sources/flume-twitter-source/src/main/java/org/apache/flume/source/twitter/TwitterSource.java
* (edit) flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java
* (edit) flume-ng-core/src/main/java/org/apache/flume/source/SequenceGeneratorSource.java


> Validate flume configuration to prevent larger source batch size than the channel transaction
capacity
> ------------------------------------------------------------------------------------------------------
>
>                 Key: FLUME-3246
>                 URL: https://issues.apache.org/jira/browse/FLUME-3246
>             Project: Flume
>          Issue Type: Improvement
>            Reporter: Endre Major
>            Assignee: Endre Major
>            Priority: Major
>             Fix For: 1.9.0
>
>




--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@flume.apache.org
For additional commands, e-mail: issues-help@flume.apache.org


Mime
View raw message