Flume
This release provides Flume 1.5.2 with no additional Apache patches.
HDP 2.6.2 provided Flume 1.5.2 and the following Apache patches:
FLUME-2427: Be less verbose in isFileClosed() notification.
FLUME-2672: NPE in KafkaSourceCounter.
FLUME-2821: Flume-Kafka Source with new Consumer.
FLUME-2822: Flume-Kafka-Sink with new Producer.
FLUME-2852: Kafka Source/Sink should optionally read/write Flume records.
FLUME-2915: The kafka channel using new APIs will be stuck when the sink is avro sink.
FLUME-2920: Kafka Channel Should Not Commit Offsets When Stopping.
FLUME-2954: Make raw data appearing in log messages explicit.
FLUME-2972: Handle offset migration in the new Kafka Channel.
FLUME-2983: Handle offset migration in the new Kafka Source.
FLUME-3114: Upgrade commons-httpclient library dependency.
HDP 2.6.1 provided Flume 1.5.2 with no additional Apache patch.
HDP 2.6.0 provided Flume 1.5.2 and the following Apache patch:
FLUME-1334: Flume startup script for Windows.
FLUME-1734: Hive Sink based on the new Hive Streaming support.
FLUME-2058: TestFlumeEventQueue in FileChannel fails on Windows.
FLUME-2068: File Channel issue - recovering from BadCheckpoint exception on Windows.
FLUME-2095: JMS source with TIBCO (patch-1).
FLUME-2122: Minor cleanups of User guide.
FLUME-2123: Morphline Solr sink missing short type name.
FLUME-2136: Fix intermittent test failure in TestMonitoredCounterGroup on Windows.
FLUME-2137: Fix StagedInstall.java to invoke the correct startup script on Windows.
FLUME-2145: TestCheckpointRebuilder.testFastReplay fails on Windows.
FLUME-2146: Windows: Tmp file creation in TestBodyTextEventSerializer.java needs fixing.
FLUME-2150: Fix TestFileChannelEncryption failure on Windows.
FLUME-2151: Windows: Update TestExecSource to use native commands on Windows.
FLUME-2162: TestHDFSEventSinkOnMiniCluster.maxUnderReplicationTest fails on hadoop2.
FLUME-2175: Update Developer Guide with notes on how to upgrade Protocol Buffer version.
FLUME-2218: TestFileChannelIntegrityTool tests failing on Windows.
FLUME-2219: Windows: Flume tests need to know location of Hadoop native libraries (hadoop.dll).
FLUME-2224: Disable File channel dual checkpointing on Windows.
FLUME-2226: Refactor BlobHandler out of morphline sink and into HTTP source.
FLUME-2227: Move BlobDeserializer from Morphline Sink to flume-ng-core.
FLUME-2337: export JAVA_HOME in flume-env.sh.template and increase heap size.
FLUME-2358: File Channel needs to close BackingStore & EventQueue before deleting files in checkpoint directory.
FLUME-2359: TestFileChannelIntegrityTool throws exception on class teardown on Windows.
FLUME-2402: Warning seen when overflow is disabled for Spillable Channel.
FLUME-2407: Spillable Channel sometimes fails on reconfigure.
FLUME-2412: Improve Logging in Spillable Channel.
FLUME-2441: Unit test TestHTTPSource.java failed with IBM JDK 1.7.
FLUME-2442: Need an alternative to providing clear text passwords in flume config.
FLUME-2450: Improve replay index insertion speed.
FLUME-2451: HDFS Sink Cannot Reconnect After NameNode Restart.
FLUME-2501: Updating HttpClient lib version to ensure compat with Solr.
FLUME-2508: LineDeserializer causes incorrect behavior in SpoolDir Source on Windows.
FLUME-2511: Allow configuration of enabled protocols in Avro source and Rpc client.
FLUME-2520: HTTP Source should be able to block a prefixed set of protocols..
FLUME-2530: Resource leaks found by Coverity tool.
FLUME-2532: Windows : TestReliableSpoolingFileEventReader - need to close filereader.
FLUME-2533: HTTPS tests fail on Java 6.
FLUME-2534: Windows : Windows : TestFlumeEventQueue has many failures.
FLUME-2541: Bug in TestBucketWriter.testSequenceFileCloseRetries.
FLUME-2586: HDFS Sink should have an option to try rename even if close fails.
FLUME-2595: Add option to checkpoint on file channel shutdown.
FLUME-2624: Streaming ingest performance improvement.
FLUME-2632: High CPU on KafkaSink.
FLUME-2655: Update documentation for hdfs.closeTries based on FLUME-2586.
FLUME-2662: Upgrade to Commons-IO 2.4.
FLUME-2663: Address Build warnings of duplicate dependencies listed.
FLUME-2722: Windows : TestKafkaSourceUtil Unit Tests fail on Windows.
FLUME-2729: Allow pollableSource backoff times to be configurable.
FLUME-2754: Hive Sink skipping first transaction in each Batch of Hive Transactions.
FLUME-2761: Move Hive sink out of preview mode.
FLUME-2804: Hive sink should try to clean up transactions when flume exits.
FLUME-2812: Fix semaphore leak causing java.lang.Error: Maximum permit count exceeded in MemoryChannel.
FLUME-2841: Upgrade commons-collections to 3.2.2.
FLUME-2854: parameterizing jetty version..
FLUME-2865: Upgrade thrift version (0.9.2).
FLUME-2947: Upgrade Hive and thrift dependencies.
FLUME-2991: ExecSource command execution starts before starting the sourceCounter.
FLUME-3031: Sequence source should reset its counter for event body on channel exception.
FULME-2544: Windows: Incorrect Path Separator used in HDFS path (HDFS Sink).