{"push_id":625217272,"size":23,"distinct_size":1,"ref":"refs/heads/FLINK-1595","head":"1316aa1431d16f3b0c790d69d6950125497f44be","before":"df727ea48c88b885222d68f48db1b7f4df3b79d3","commits":[{"sha":"2ffefdfb3c7c562d907ad1a4cdc9cd951a29fcaf","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[yarn][streaming] Add support for streaming fire and forget yarn job submissions.","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/2ffefdfb3c7c562d907ad1a4cdc9cd951a29fcaf"},{"sha":"2cbbd3287252fd33472ae52cfa6a6b38b3b1c39e","author":{"email":"1dc673e4ad3419cf51d1e2606f688dd937061d98@gmail.com","name":"Kostas Tzoumas"},"message":"Added support for Apache Tez as an execution environment\n\nThis closes #189","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/2cbbd3287252fd33472ae52cfa6a6b38b3b1c39e"},{"sha":"2d55cf0dcbdf2fd182e690209bc86e898f9e01d8","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-1788] [table] Make logical plans transformable","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/2d55cf0dcbdf2fd182e690209bc86e898f9e01d8"},{"sha":"189001d8093c66b7d7e63f196aa71c9928021d50","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[FLINK-1803] [streaming] returns(..) method added to Stream operators\n\nThis closes #556","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/189001d8093c66b7d7e63f196aa71c9928021d50"},{"sha":"b8bb762e38ef159f0d11311760202d33933811e5","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[release scripts] Update scripts for 0.9.0-milestone1","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/b8bb762e38ef159f0d11311760202d33933811e5"},{"sha":"dda8565e6b4f519ac77d66d710a5dc64f1c5740b","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[FLINK-1656] Filter ForwardedField properties for group-at-a-time operators in Optimizer.\n\nThis closes #525","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/dda8565e6b4f519ac77d66d710a5dc64f1c5740b"},{"sha":"f39aec82d6cd1286f129b11366d101cb646716ee","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[FLINK-1776] Add offsets to field indexes of semantic properties for operators with key selectors\n\nThis closes #532","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/f39aec82d6cd1286f129b11366d101cb646716ee"},{"sha":"f36eb54ee6d8cc130439def98559b6b0a70b6c7b","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[FLINK-1664] Adds check if a selected sort key is sortable\n\nThis closes #541","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/f36eb54ee6d8cc130439def98559b6b0a70b6c7b"},{"sha":"909cee281292be7408b1b9f0c25cfbd6cf185b4a","author":{"email":"37359766164a1f05e02dc4cb3d9782b5cf427874@huawei.com","name":"hongsibao"},"message":"Fix the constructor comments with correct parameter in DefaultMemoryManager\n\nCloses #568","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/909cee281292be7408b1b9f0c25cfbd6cf185b4a"},{"sha":"1cf49e90cddea610b4cfa3623a53ced66aadfc2d","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[FLINK-1824] [streaming] Support added for missing types in DataStream api\n\nCloses #567","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/1cf49e90cddea610b4cfa3623a53ced66aadfc2d"},{"sha":"1da4b6437e33f794dd3603f029010f0cc70607d1","author":{"email":"5c0368c5ea0c499c138380b3bfb02f5776cce689@gmail.com","name":"Paris Carbone"},"message":"[FLINK-1808] [streaming] Send barrier requests only when the execution graph is running\n\nCloses #551","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/1da4b6437e33f794dd3603f029010f0cc70607d1"},{"sha":"e74521c1fe5f5842185be5c454d27adc3bd254d5","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"    [FLINK-1580] [taskmanager] Improve TaskManager startup robustness\n\n     - Initialize network buffer pool and memory manager before the\n       asynchronous actor start\n\n     - Split messages into more topic-related groups\n\n     - Split message handling logic on TaskManager into topic-related functions\n\n     - Simplify registration logic\n\n     - Add a lot of tests that validate\n       - task manager configuration checking\n       - task manager registration\n       - task manager re-registration on failures/disconnects","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/e74521c1fe5f5842185be5c454d27adc3bd254d5"},{"sha":"43c080aeb1d8a6644cf8a7fe7c55e7f1151dc62c","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[runtime] Simplify TaskExecutionState by removing obsolete manual serialization code.","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/43c080aeb1d8a6644cf8a7fe7c55e7f1151dc62c"},{"sha":"adc85301cfb25cedce996d91f5aae69a2c597879","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[runtime] Fix bug that deploys to wrong target TaskManager slot","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/adc85301cfb25cedce996d91f5aae69a2c597879"},{"sha":"12c555f5f31aa6a14d39d2a96bcf7412ec17495f","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[runtime] Remove old redundant classes\n  - StringRecord -> StringValue\n  - IntegerRecord -> IntValue\n  - FileRecord -> obsolete","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/12c555f5f31aa6a14d39d2a96bcf7412ec17495f"},{"sha":"4f4c6b90d5a0b452f8c6f8ad033ecc9e710fcd55","author":{"email":"02f9d0fc2069624b53c1abca866f8dd32321b502@apache.org","name":"mbalassi"},"message":"[streaming] WindowWordCount example added","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/4f4c6b90d5a0b452f8c6f8ad033ecc9e710fcd55"},{"sha":"0ca1f0c7b76cc4b4199fb687be4592dbd1548757","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[runtime] Add docs to BufferPool classes","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/0ca1f0c7b76cc4b4199fb687be4592dbd1548757"},{"sha":"4ed009ec9921e998161f82bc78137429986e2ba3","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[TaskManager] Add test for failure behavior on TaskManager startup","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/4ed009ec9921e998161f82bc78137429986e2ba3"},{"sha":"5cd9e9d94bb3af4a5a868789f663af262672cac8","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[runtime] Improve robustness of test TaskManagerRegistrationTest.\n\nAlso rename jobmanager.TaskManagerRegistrationTest to avoid name conflicts.","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/5cd9e9d94bb3af4a5a868789f663af262672cac8"},{"sha":"8f2556c2e5a38ce84ede0f7120727714fe9fb18a","author":{"email":"e2b6273a9ee2eb0c766f7abab122899bc38b9bcc@gmail.com","name":"szape"},"message":"[FLINK-1560] [streaming] Streaming examples rework","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/8f2556c2e5a38ce84ede0f7120727714fe9fb18a"}]}