{"push_id":771326970,"size":9,"distinct_size":9,"ref":"refs/heads/master","head":"17e5c8effd8c7b7427e585af80b813901c6ffb96","before":"4a5fe4e631d53c0c940c2899978ee72e23690c86","commits":[{"sha":"ef76c777539caba378593d76e63dabdd8178df39","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-2578] [tests] Fix stability of TaskAsyncCallTest","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/ef76c777539caba378593d76e63dabdd8178df39"},{"sha":"2a375e4c8b5557a8504977cb4b793313364cacdd","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-2276] [tests] Fix stability of TaskTest","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/2a375e4c8b5557a8504977cb4b793313364cacdd"},{"sha":"851951ab18f4fe08d1c75679489c2dc9cacbf6dc","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@informatik.hu-berlin.de","name":"mjsax"},"message":"[FLINK-2553] Example Jars not build correctly\n  - reworked package structure of utils and wordcount.stormoperators package\n  - reword class hierarchy of *FileSpout and *InMemorySpout\n  - fixed pom.xml to assembly jars correctly\n  - simplified example jar file names\n  - replace maven-assembly-plugin with maven-shade-plugin (removed assembly.xml file)\n  - extended README and documenation to building and using correct jars\nadditional minor changes:\n - comment typo in FlinkSubmitter\n - removed version number in hardcoded jar file name\n\nThis closes #1037","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/851951ab18f4fe08d1c75679489c2dc9cacbf6dc"},{"sha":"57e6d9dff21f5fe39b7dcebb69be01643b077996","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-2386] [kafka connector] Add new Kafka Consumer for Flink\n\nThis closes #996","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/57e6d9dff21f5fe39b7dcebb69be01643b077996"},{"sha":"bdd75cb427540337059d4e904c39a4348555d9e6","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[streaming] Cleanup de-/serialization schema, add TypeInformationSerializationSchema prominent, add tests.","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/bdd75cb427540337059d4e904c39a4348555d9e6"},{"sha":"bccb06badde9925b18b507310a6fe6e8d608aac3","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport'","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/bccb06badde9925b18b507310a6fe6e8d608aac3"},{"sha":"8d1b3b231483de9171d3f4850479204607e5c7d7","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-2386] [kafka connector] Refactor, cleanup, and fix kafka consumers","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/8d1b3b231483de9171d3f4850479204607e5c7d7"},{"sha":"0bfd27a62b09cb9be872cb7c638bd54e625b5b4c","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval.\n\nThis closes #1039","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/0bfd27a62b09cb9be872cb7c638bd54e625b5b4c"},{"sha":"17e5c8effd8c7b7427e585af80b813901c6ffb96","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-2386] [kafka connector] Move Kafka connector classes to 'org.apache.flink.streaming.connectors.kafka'","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/17e5c8effd8c7b7427e585af80b813901c6ffb96"}]}