{"push_id":1052147790,"size":43,"distinct_size":43,"ref":"refs/heads/master","head":"b1e5086455257e5b7d967fd0715f5a2ab30734aa","before":"76da442837d8606d8c4c4d8367b29fd79dc5ba35","commits":[{"sha":"f7a3c8104db2a0171ce78aad16ad5e51f4bb9eaf","author":{"email":"62c32629769998ef6046bdefb2e2837613227b91@apache.org","name":"smarthi"},"message":"FLINK-3115: Update ElasticSearch connector to 2.x\n\nThis closes #1792","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/f7a3c8104db2a0171ce78aad16ad5e51f4bb9eaf"},{"sha":"8e4a001b84c36827eb6168adac2724f76e30cc2c","author":{"email":"a47d0c84e35042eed4634dc240ddb5dd2cf54b11@gmail.com","name":"Ajay Bhat"},"message":"[FLINK-2445] Add tests for HadoopOutputFormats\n\nThis closes #1486","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/8e4a001b84c36827eb6168adac2724f76e30cc2c"},{"sha":"bcb34dd57fb4c9908cd8525db6fd7db3d4c6d254","author":{"email":"d22fe4c37466fd2128f6ceeb947bbfb4c52e5900@gmail.com","name":"Martin Liesenberg"},"message":"[FLINK-2445] Improve HadoopOutputFormatTests\n\nThis closes #1628","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/bcb34dd57fb4c9908cd8525db6fd7db3d4c6d254"},{"sha":"a6c3778fd892398d2a6b9c4a02eee1613eda3f42","author":{"email":"d22fe4c37466fd2128f6ceeb947bbfb4c52e5900@gmail.com","name":"Martin Liesenberg"},"message":"[FLINK-2444] Add tests for HadoopInputFormats\n\nThis closes #1628","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/a6c3778fd892398d2a6b9c4a02eee1613eda3f42"},{"sha":"b8299bf92d8e3dbe140dd89602699394019b783d","author":{"email":"6cd8718626a16063cc3afa941dc9715c0845c635@126.com","name":"gallenvara"},"message":"[FLINK-2997] [dataSet] Add support for range partitioning with custom data distribution.\n\nThis closes #1776","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/b8299bf92d8e3dbe140dd89602699394019b783d"},{"sha":"27dfd8651b92598fdbf528d4faedbf05e3857ca6","author":{"email":"be6db939736cf17c8d472b20215ee8d72e346aca@radicalbit.io","name":"Stefano Baghino"},"message":"[FLINK-3653] [docs] Add recovery.zookeeper.storageDir docs to config page\n\nThis closes #1828.","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/27dfd8651b92598fdbf528d4faedbf05e3857ca6"},{"sha":"f0b6ba46db97da742164cee0cad91e22e7c9138f","author":{"email":"10fd0344fd208b6f74722ad6575686df229f1765@godatadriven.com","name":"Niels Zeilemaker"},"message":"[FLINK-3663] [kafka] Fix logPartitionInfo log statement\n\nThis closes #1835.","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/f0b6ba46db97da742164cee0cad91e22e7c9138f"},{"sha":"c77e5ece581cbaaa423f38318d6735a222cf3cd5","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-3658][Kafka] Allow producing into multiple topics\n\nThis closes #1832","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/c77e5ece581cbaaa423f38318d6735a222cf3cd5"},{"sha":"5108f6875f102e613d70cc90fd13d269465f2bff","author":{"email":"f55f5fad55aaea3a24db3b0da6267c06dda1c57a@apache.org","name":"Chiwan Park"},"message":"[FLINK-2935] [scala-shell] Allow Scala shell to connect Flink cluster on YARN\n\n  - Remove duplicated parseHostPortAddress method (Move it to ClientUtils class)\n  - Refactor FlinkShell class\n\nThis closes #1500.","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/5108f6875f102e613d70cc90fd13d269465f2bff"},{"sha":"2da562b429cb6479abd971ff2ccc8a990b43bf59","author":{"email":"6873ed71afbc9d34f235a1376a902115740ccfeb@apache.org","name":"vasia"},"message":"[FLINK-3639] add methods for registering datasets and tables in the TableEnvironment\n\nThis closes #1827","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/2da562b429cb6479abd971ff2ccc8a990b43bf59"},{"sha":"b21e63c6421bbc949125188cc7a68c57f99c121b","author":{"email":"be6db939736cf17c8d472b20215ee8d72e346aca@radicalbit.io","name":"Stefano Baghino"},"message":"[hotfix] [docs] Fix a couple of typos in YARN documentation\n\nThis closes #1836.","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/b21e63c6421bbc949125188cc7a68c57f99c121b"},{"sha":"92ff2b152cac3ad6a53373c0c022579306051133","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[FLINK-3544][runtime] introduce ResourceManager component\n\nThis closes #1741.","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/92ff2b152cac3ad6a53373c0c022579306051133"},{"sha":"4405235e5483d3e4ad94f4ba31627aa852580042","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[FLINK-3545][yarn] integrate ResourceManager support","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/4405235e5483d3e4ad94f4ba31627aa852580042"},{"sha":"f773fe05d1663ffaa92c2328c07e68a645d8b553","author":{"email":"6873ed71afbc9d34f235a1376a902115740ccfeb@apache.org","name":"vasia"},"message":"[FLINK-3547] add support for DataStreamTable\n\n- add Java and Scala stream translators\n\n- add DataStream rules for calc and scan\n\n- add tests and streaming test utils\n\n- add support for streaming union\n\n- move code generation from the calc rule to the calc node\nand remove unnecessary rules\n\n- refactoring to reuse code between dataset and datastream translation\n\nThis closes #1820","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/f773fe05d1663ffaa92c2328c07e68a645d8b553"},{"sha":"2e4498bd3bda6633b34d20f44170f034bf6faf7a","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[FLINK-3676][docs] sync docs with the WebClient removal","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/2e4498bd3bda6633b34d20f44170f034bf6faf7a"},{"sha":"580a1778c1e6a25639218daaf618570ea30e3621","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-3651] Fix faulty RollingSink Restore\n\nOn restore the sink for subtask index i has to cleanup leftover files\nfor subtask i. The pattern used for checking this was not properly\nterminated so the sink for subtask 1 would, for example, delete some\nfiles for sink i=11. This would lead to data loss.\n\nThis closes #1830","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/580a1778c1e6a25639218daaf618570ea30e3621"},{"sha":"f08b7c913c235c827fdc850ef1897ea508aadba6","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[hotfix] [cep] Add sanity check for erroneously pruned elements","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/f08b7c913c235c827fdc850ef1897ea508aadba6"},{"sha":"833339f3a0faafbab9af90433488393421ae7171","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[FLINK-3681] [cep, typeextractor] Generalize TypeExtractor to support more lambdas\n\nThe TypeExtractor.getUnaryOperatorReturnType and TypeExtractor.getBinaryOperatorReturnType\nmethods have been extended to support positional arguments for the input types. This allows\nto support parameterized types as Java 8 lambda arguments where the input type is not specified\nby the first type argument (e.g. Map<String, T>). This also solves the problem that the CEP\nlibrary did not support Java 8 lambdas as select functions.\n\nThis closes #1840.","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/833339f3a0faafbab9af90433488393421ae7171"},{"sha":"bdf55b90d58e3d7cb1f9b4ee0c2780bcca1c8f8a","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[FLINK-3682] [cep] Assign processing timestamp in CEP operators\n\nThis PR fixes the problem that the CEP operators did not assign the wall clock time\nas the timestamp to incoming in StreamRecords if the TimeCharacteristic was set to\nProcessingTime. Processing element with a Long.MIN_VALUE timestamp can lead to underflows\nin the NFA if a positive window length is subtracted from the timestamp. For this\nunderflow a sanity check has been added to notify the user with an exception about it.\n\nThis closes #1841.","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/bdf55b90d58e3d7cb1f9b4ee0c2780bcca1c8f8a"},{"sha":"e3759a5e65181040066dbb278266f2c1fa226347","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[FLINK-3684] [cep] Add proper watermark emission to CEP operators\n\nThis closes #1842.","distinct":true,"url":"https://api.github.com/repos/zentol/flink/commits/e3759a5e65181040066dbb278266f2c1fa226347"}]}