{"push_id":1351879492,"size":24,"distinct_size":24,"ref":"refs/heads/trunk","head":"87d4c2c13862144eb578b211bcf800b2206834ff","before":"4b74aa286b16916900854ccea95cf906d3fdda5d","commits":[{"sha":"1422f733007dbb78caae7e5135bc33470e88502a","author":{"name":"Bessenyei Balázs Donát","email":"d62808e167ff6b61d6b7c271a9ee93d6ce177725@cloudera.com"},"message":"FLUME-2619. Spooldir source should log channel exceptions\n\nReviewed by Denes Arvay and Mike Percy.\n\n(Bessenyei Balázs Donát via Mike Percy)","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/1422f733007dbb78caae7e5135bc33470e88502a"},{"sha":"c1fae53bf2c254f5cf1282f32116a7aedc5340ed","author":{"name":"Roshan Naik","email":"ba025de8aede9d5543fba402d72f66391168148b@hortonworks.com"},"message":"FLUME-2901. Document Kerberos setup for Kafka channel\n\nAdd details about configuring Kafka channel to work with a Kerberized\nKafka cluster.\n\n(Roshan Naik via Mike Percy)","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/c1fae53bf2c254f5cf1282f32116a7aedc5340ed"},{"sha":"b6dede8c108e0d8e3516767de31e3a847c69cfe0","author":{"name":"Bessenyei Balázs Donát","email":"d62808e167ff6b61d6b7c271a9ee93d6ce177725@cloudera.com"},"message":"FLUME-2318: Make SpoolingDirectorySource able to handle empty files\n\n(Muhammad Ehsan ul Haque and Bessenyei Balázs Donát via Mike Percy)","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/b6dede8c108e0d8e3516767de31e3a847c69cfe0"},{"sha":"118d5a4bcf5371fb215e0f7393fadf26073643f8","author":{"name":"Denes Arvay","email":"755fe1cf8c2faeedc74782d7a7abc8935f377351@cloudera.com"},"message":"FLUME-2844. SpillableMemoryChannel must start ChannelCounter\n\nReviewed by Bessenyei Balázs Donát\n\n(Denes Arvay via Mike Percy)","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/118d5a4bcf5371fb215e0f7393fadf26073643f8"},{"sha":"e0deb7281fce0f6937f20da305b58d52d9a67a94","author":{"name":"Bessenyei Balázs Donát","email":"d62808e167ff6b61d6b7c271a9ee93d6ce177725@cloudera.com"},"message":"FLUME-2975. docs: Fix NetcatSource example\n\n(Bessenyei Balázs Donát via Mike Percy)","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/e0deb7281fce0f6937f20da305b58d52d9a67a94"},{"sha":"9eb92dab0d24813e9a3871f0c7038920797c0466","author":{"name":"Bessenyei Balázs Donát","email":"d62808e167ff6b61d6b7c271a9ee93d6ce177725@cloudera.com"},"message":"FLUME-2974. Fix some broken SpoolDirSource unit tests\n\nTestReliableSpoolingFileEventReader and TestSpoolingFileLineReader were\nbroken as part of commit b6dede8c108e0d8e3516767de31e3a847c69cfe0.\nThis patch fixes them again.\n\n(Bessenyei Balázs Donát via Mike Percy)","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/9eb92dab0d24813e9a3871f0c7038920797c0466"},{"sha":"1e8f2651dacf5daef55d75c7b9b12492962e7921","author":{"name":"Grant Henke","email":"92cb0c65dbf8ff1baaf010de530f6f36b8383062@gmail.com"},"message":"FLUME-2972. Handle offset migration in the new Kafka Channel\n\nOffsets tracking the position in Kafka consumers change from using\nZookeeper for offset storage to Kafka when moving from Kafka 0.8.x to\n0.9.x.\n\nFLUME-2823 makes the client change in the Kafka Channel but does not\nensure existing offsets get migrated in order to continue consuming\nwhere it left off.\n\nFlume should have some automated logic on startup to check if Kafka\noffsets exist, if not and migration is enabled (by default) then copy\nthe offsets from Zookeeper and commit them to Kafka.\n\nReviewers: Balázs Donát Bessenyei, Denes Arvay, Mike Percy\n\n(Grant Henke via Mike Percy)","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/1e8f2651dacf5daef55d75c7b9b12492962e7921"},{"sha":"25e4bc6d80cf475862a1686fb2c3c97fcea27278","author":{"name":"Attila Simon","email":"bad7e4fb82698a9519e7ea871db6f9f720e890ca@cloudera.com"},"message":"FLUME-2954. Make raw data appearing in log messages explicit\n\nFlume has built-in functionality to log data flowing through, mainly for\ndebugging purposes. This functionality appears in several places in the\ncode base. Such functionality can raise security concerns in production\nenvironments where sensitive information might be ingested so it is\ncrucial that enabling such functionality be as explicit as possible.\n\nThis patch adds two system properties, one to enable logging of Flume\nconfiguration properties and one to enable logging of raw data. If they\nare not set, these items are never logged at any log4j logging level.\n\nReviewers: Balázs Donát Bessenyei, Denes Arvay, Mike Percy\n\n(Attila Simon via Mike Percy)","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/25e4bc6d80cf475862a1686fb2c3c97fcea27278"},{"sha":"53fb37443eec3261b32f39cb363183988498e47f","author":{"name":"Mike Percy","email":"cff85361dbf37727974f83050b578c44b3a5c729@apache.org"},"message":"Upgrade to ASF pom version 18\n\nThis gets rid of some annoying warning messages from RAT, such as:\n\nWarning:  org.apache.xerces.jaxp.SAXParserImpl$JAXPSAXParser: Property 'http://www.oracle.com/xml/jaxp/properties/entityExpansionLimit' is not recognized.\nCompiler warnings:\n  WARNING:  'org.apache.xerces.jaxp.SAXParserImpl: Property 'http://javax.xml.XMLConstants/property/accessExternalDTD' is not recognized.'\nWarning:  org.apache.xerces.parsers.SAXParser: Feature 'http://javax.xml.XMLConstants/feature/secure-processing' is not recognized.\nWarning:  org.apache.xerces.parsers.SAXParser: Property 'http://javax.xml.XMLConstants/property/accessExternalDTD' is not recognized.\nWarning:  org.apache.xerces.parsers.SAXParser: Property 'http://www.oracle.com/xml/jaxp/properties/entityExpansionLimit' is not recognized.\n\nReviewers: Bessenyei Balázs Donát, Hari Shreedharan\n\nThis closes #63.","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/53fb37443eec3261b32f39cb363183988498e47f"},{"sha":"330e572879c9903f5b1084d84b237685aa9970c6","author":{"name":"Grant Henke","email":"92cb0c65dbf8ff1baaf010de530f6f36b8383062@gmail.com"},"message":"FLUME-2983. Handle offset migration in the new Kafka Source\n\nSimilar to FLUME-2972, offsets tracking the position in Kafka consumers\nchange from using zookeeper for offset storage to Kafka when moving from\n0.8.x to 0.9.x.\n\nFLUME-2821 makes the client change in the Kafka Source but does not\nensure existing offsets get migrated in order to continue consuming\nwhere it left off. Flume should have some automated logic on startup to\ncheck if Kafka offsets exist, if not and migration is enabled (by\ndefault) then copy the offsets from Zookeeper and commit them to Kafka.\n\nThis change should also fix the backwards incompatibility caused by\nremoving the zookeeperConnect property. The bootstrap can be looked up\nif zookeeperConnect is used.\n\nReviewers: Denes Arvay, Mike Percy\n\n(Grant Henke via Mike Percy)","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/330e572879c9903f5b1084d84b237685aa9970c6"},{"sha":"a0a50849d5ad33e6e6903316a3bd3dbba8547843","author":{"name":"Jeff Holoman","email":"617c80b627c9e807d837dd041ac28956375eb3e8@gmail.com"},"message":"FLUME-2982. Add localhost escape sequence to HDFS sink\n\nIt would be useful to be able to just use %[localhost] escape sequence\ninstead of having to pass in a header or use the host interceptor.\n\nPart of the problem of using an interceptor is the case where Flume only\nconsists of a channel and a sink (think KafkaChannel). There is support\nin Flume for a sink-side interceptor at the time of this writing.\n\nReviewers: Grant Henke, Mike Percy\n\n(Jeff Holoman via Mike Percy)","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/a0a50849d5ad33e6e6903316a3bd3dbba8547843"},{"sha":"d9c9a7dd9a6889ecf6b9dc88fb8e02ccc1cd5167","author":{"name":"Denes Arvay","email":"755fe1cf8c2faeedc74782d7a7abc8935f377351@cloudera.com"},"message":"FLUME-2797. Use SourceCounter for SyslogTcpSource\n\nThis patch uses the newer SourceCounter class for the SyslogTcpSource.\nIt also marks the SyslogTcpSource as deprecated and improves how the\nunit tests are written so they don't require DNS.\n\nReviewers: Attila Simon, Lior Zeno, Balázs Donát Bessenyei, Mike Percy\n\n(Denes Arvay via Mike Percy)","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/d9c9a7dd9a6889ecf6b9dc88fb8e02ccc1cd5167"},{"sha":"591b138321280cea1e7d61efcaf625a67202cb3d","author":{"name":"Siddharth Ahuja","email":"9a98ce18e988b8068183c4c95d361a6855282909@cloudera.com"},"message":"FLUME-2966. Fix NPE in JMS Source\n\nJMS Source does not check for null text in a TextMessage. This can lead to NullPointerException.\nThis commit fixes that problem by checking for nullity of textMessage.getText().\n\nReviewers: Denes Arvay, Attila Simon, Mike Percy, Bessenyei Balázs Donát\n\n(Siddharth Ahuja via Bessenyei Balázs Donát)","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/591b138321280cea1e7d61efcaf625a67202cb3d"},{"sha":"fca8c5b970cf0bbae61bae08f2084dd4f3bd1143","author":{"name":"Attila Simon","email":"bad7e4fb82698a9519e7ea871db6f9f720e890ca@cloudera.com"},"message":"FLUME-2998. Add a missing configuration parameter to SequenceSource docs\n\nSequenceSource's totalEvents is configurable, but it is not in the documentation.\n\nThis patch fixes that problem by adding the missing configuration parameter to the docs.\n\nReviewers: Denes Arvay, Bessenyei Balázs Donát\n\n(Attila Simon via Bessenyei Balázs Donát)","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/fca8c5b970cf0bbae61bae08f2084dd4f3bd1143"},{"sha":"27c725802b16915acaa3ea05cdac0236972af1f0","author":{"name":"Denes Arvay","email":"755fe1cf8c2faeedc74782d7a7abc8935f377351@cloudera.com"},"message":"FLUME-3003. Fix flaky testSourceCounter in TestSyslogUdpSource\n\nThe event processing in SyslogUDPSource is handled on a separate thread by Netty so message delivery, thus the sourceCounter's increment can be delayed resulting in a flaky test.\n\nThis patch fixes that issue by adding more delay when necessary.\n\nReviewers: Lior Zeno, Bessenyei Balázs Donát\n\n(Denes Arvay via Bessenyei Balázs Donát)","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/27c725802b16915acaa3ea05cdac0236972af1f0"},{"sha":"7d5ceacac49f5d15bf8f75e0209592c5524a3dda","author":{"name":"Andrea Rota","email":"172329fdc9449607dd08403d2c998ee82969f5ab@gmail.com"},"message":"FLUME-2911. Add include pattern option in SpoolDir source\n\n* Documented what happens when ignorePattern and includePattern both\n  match for a given file.\n* Added two tests to simulate what happens when both ignorePattern and\n  includePattern options are specified\n* Refactored of ReliableSpoolingFileEventReader test and fix of code\n  style violations\n\nCloses #60\n\nReviewers: Bessenyei Balázs Donát, Denes Arvay, Attila Simon\n\n(Andrea Rota via Mike Percy)","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/7d5ceacac49f5d15bf8f75e0209592c5524a3dda"},{"sha":"585c4c92ed65c529871765ab64a5b3637fbdb07d","author":{"name":"Tristan Stevens","email":"f80a9c5a38e2f94081a127e59e7d6c6adbd45c55@cloudera.com"},"message":"FLUME-2999. Kafka channel and sink should enable statically assigned partition per event via header\n\nThis feature is useful for anyone who needs greater control of which\npartitions are being written to - normally in a situation where multiple\nFlume agents are being deployed in order to horizontally scale, or\nalternatively if there is a scenario where there is a skew in data that\nmight lead to one or more partitions hotspotting.\n\nWe also have the ability to specify custom partitions on to the Kafka\nProducer itself using the kafka.* configuration properties. The Kafka\nProducer provides the ability to set the partition ID using a particular\nProducerRecord constructor, this is just a matter of providing the\noption to use this constructor.\n\nReviewers: Attila Simon, Mike Percy\n\n(Tristan Stevens via Mike Percy)","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/585c4c92ed65c529871765ab64a5b3637fbdb07d"},{"sha":"2fd0d2572ceb2bc0138c880a3b763647349b64f4","author":{"name":"Attila Simon","email":"bad7e4fb82698a9519e7ea871db6f9f720e890ca@cloudera.com"},"message":"FLUME-2971. Add secure Kafka Sink/Source/Channel setup to the User Guide\n\nThe User Guide already has details about configuring Kafka channel to work with a kerberized Kafka cluster.\n\nThis patch adds similar description for Kafka Sink and Kafka Source.\n\nReviewers: Tristan Stevens, Mike Percy, Bessenyei Balázs Donát\n\n(Attila Simon via Bessenyei Balázs Donát)","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/2fd0d2572ceb2bc0138c880a3b763647349b64f4"},{"sha":"d40abcbfbf31528dbbb1739118ddb1dc60bfbeeb","author":{"name":"Bessenyei Balázs Donát","email":"d62808e167ff6b61d6b7c271a9ee93d6ce177725@apache.org"},"message":"Update RELEASE-NOTES for 1.7.0","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/d40abcbfbf31528dbbb1739118ddb1dc60bfbeeb"},{"sha":"5e400ea8c471ef41c12dd8ad2079ac8a351ec509","author":{"name":"Bessenyei Balázs Donát","email":"d62808e167ff6b61d6b7c271a9ee93d6ce177725@apache.org"},"message":"Update CHANGELOG for 1.7","distinct":true,"url":"https://api.github.com/repos/Popo-lth/flume/commits/5e400ea8c471ef41c12dd8ad2079ac8a351ec509"}]}
{"actor":{"display_login":"Popo-lth"}}