{"push_id":640809603,"size":26,"distinct_size":13,"ref":"refs/heads/flink1875","head":"db608332e71b7202dde31180fe9f543eb7e5cca7","before":"f20fc85910834e2b37ad673a2f3402dce1151d8e","commits":[{"sha":"354922bed7ffe5482513ac53b5ef56bfbca8bd9a","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-1753] Extend KafkaITCase with large messages test + rework PersistentKafkaSource.\n\nThis closes #603","distinct":false,"url":"https://api.github.com/repos/rmetzger/flink/commits/354922bed7ffe5482513ac53b5ef56bfbca8bd9a"},{"sha":"8c5cd97356ee978c1e9a5b73b90677cfd1eef164","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-1900] Fix Scala Table API Example in doc","distinct":false,"url":"https://api.github.com/repos/rmetzger/flink/commits/8c5cd97356ee978c1e9a5b73b90677cfd1eef164"},{"sha":"c2faa6fe3aca39d9648a7e4b57ef797746c28aa9","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-1856][doc] Add notice about implicit TypeInformation","distinct":false,"url":"https://api.github.com/repos/rmetzger/flink/commits/c2faa6fe3aca39d9648a7e4b57ef797746c28aa9"},{"sha":"ea710204e4d1ac6ac6d3e6ce31215aa0b8ff50b1","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[streaming][connectors] Add more configuration options to PersistentKafkaSource\n\nThis closes #607","distinct":false,"url":"https://api.github.com/repos/rmetzger/flink/commits/ea710204e4d1ac6ac6d3e6ce31215aa0b8ff50b1"},{"sha":"32a04e42d8766ecdfe0db0516b899008bd3d0c3e","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[docs] Corrects combineGroup documentation example","distinct":false,"url":"https://api.github.com/repos/rmetzger/flink/commits/32a04e42d8766ecdfe0db0516b899008bd3d0c3e"},{"sha":"10fc1d8d3374ef05c4c5430b1d7a5aaa63ee9185","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-1902] Show jobmanager address/port in configuration","distinct":false,"url":"https://api.github.com/repos/rmetzger/flink/commits/10fc1d8d3374ef05c4c5430b1d7a5aaa63ee9185"},{"sha":"26ce47f52e7d533f069b18d13e2e01aa9e56a483","author":{"email":"73225862d7adfabe295c527de212d1180417f1ae@googlemail.com","name":"FelixNeutatz"},"message":"[FLINK-1900] add missing '","distinct":false,"url":"https://api.github.com/repos/rmetzger/flink/commits/26ce47f52e7d533f069b18d13e2e01aa9e56a483"},{"sha":"f7ec859e8a819d2e1348e4b6612c53e1d18d3d52","author":{"email":"37359766164a1f05e02dc4cb3d9782b5cf427874@huawei.com","name":"hongsibao"},"message":"Fix the message in runtime exception\n\nThis closes #599","distinct":false,"url":"https://api.github.com/repos/rmetzger/flink/commits/f7ec859e8a819d2e1348e4b6612c53e1d18d3d52"},{"sha":"e2a00183eb539889d7a5053c49b2a296de79add0","author":{"email":"57926a7d0b95c68919768258cf0ccf8e8d843814@gmail.com","name":"Akshay Dixit"},"message":"[docs] fixed a few typos in internal_general_arch.md\n\nThis closes #602","distinct":false,"url":"https://api.github.com/repos/rmetzger/flink/commits/e2a00183eb539889d7a5053c49b2a296de79add0"},{"sha":"a0900e7324b7a2f85080d151ab5ed1f015c257df","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[streaming] Parallel time reduce logic refactor to force prereducers","distinct":false,"url":"https://api.github.com/repos/rmetzger/flink/commits/a0900e7324b7a2f85080d151ab5ed1f015c257df"},{"sha":"6a1edc8edcc576896106730cbb537886e5afa09a","author":{"email":"f55f5fad55aaea3a24db3b0da6267c06dda1c57a@icloud.com","name":"Chiwan Park"},"message":"[FLINK-1906] [docs] Add tip to work around plain Tuple return type of project operator\n\nThis closes #611","distinct":false,"url":"https://api.github.com/repos/rmetzger/flink/commits/6a1edc8edcc576896106730cbb537886e5afa09a"},{"sha":"62c3d509515213042beb226812051d51c7339999","author":{"email":"ac0d1dd469512ba8c9a2ea9b4bae5dc8b56612ea@gmail.com","name":"fobeligi"},"message":"[FLINK-1809] Add Preprocessing package and Standardizer to ML-library\n\n[FLINK-1809] Add documentation for Standard Scaler\n\n[FLINK-1809] [ml] Integrates standard scaler documentation into the web site\n\nThis closes #579.","distinct":false,"url":"https://api.github.com/repos/rmetzger/flink/commits/62c3d509515213042beb226812051d51c7339999"},{"sha":"877043f9109e901c56c4a3185e0923e70d6cc0aa","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[streaming] Fixes kafka test logging","distinct":false,"url":"https://api.github.com/repos/rmetzger/flink/commits/877043f9109e901c56c4a3185e0923e70d6cc0aa"},{"sha":"af9248c35a5a138d311073b54f6abd4260ab7fd9","author":{"email":"f6773562c9b47f90844286155b23bf8af2851ee5@web.de","name":"zentol"},"message":"[FLINK-377] Generic Interface","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/af9248c35a5a138d311073b54f6abd4260ab7fd9"},{"sha":"d182daa19eeb1d3877821d4a8b9a37311678a12f","author":{"email":"f6773562c9b47f90844286155b23bf8af2851ee5@web.de","name":"zentol"},"message":"[FLINK-671] Python API","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/d182daa19eeb1d3877821d4a8b9a37311678a12f"},{"sha":"1d669dabd23fb15c168cdbabe60810f0735ad83d","author":{"email":"caf9afd54ab7e996a107d1c56a2b304d9c0643c8@gmail.com","name":"mingliang"},"message":"Added examples of TPCH Query 3 and Query 10, WebLogAnalysis","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/1d669dabd23fb15c168cdbabe60810f0735ad83d"},{"sha":"e1618e287885390c9ea1d4954ea18eeed5783b4a","author":{"email":"f6773562c9b47f90844286155b23bf8af2851ee5@web.de","name":"zentol"},"message":"[Flink-671] Python API additions\n\nFixes several minor issues\nRequesting non-available data throws Exception\nPython process shutodwn more reliable\nSynchronization done via TCP","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/e1618e287885390c9ea1d4954ea18eeed5783b4a"},{"sha":"30a74c768b88043c173053f5d37bfb0fde85f149","author":{"email":"f55f5fad55aaea3a24db3b0da6267c06dda1c57a@icloud.com","name":"Chiwan Park"},"message":"[FLINK-703] [java api] Use complete element as join key","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/30a74c768b88043c173053f5d37bfb0fde85f149"},{"sha":"45e680c2b6c9c2f64ce55423b755a13d402ff8ba","author":{"email":"f55f5fad55aaea3a24db3b0da6267c06dda1c57a@icloud.com","name":"Chiwan Park"},"message":"[FLINK-703] [scala api] Use complete element as join key\n\nThis closes #572","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/45e680c2b6c9c2f64ce55423b755a13d402ff8ba"},{"sha":"a0147c493cf210a0914c35200ebfacd47515374d","author":{"email":"37359766164a1f05e02dc4cb3d9782b5cf427874@huawei.com","name":"hongsibao"},"message":"[FLINK-1891] Add check for empty storageDirectory path\n\nThis closes #601","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/a0147c493cf210a0914c35200ebfacd47515374d"}]}