{"push_id":885504449,"size":16,"distinct_size":13,"ref":"refs/heads/master","head":"31f6a744c78adcb4f702da3cbabe7d462a66184e","before":"e9a2bc9d0467a8b0f61caab1b36b2f738f8bfc0e","commits":[{"sha":"a997dd615598650934f0b785cbe8a6468ea63481","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-3081] Properly stop periodic Kafka committer\n\nThis closes #1410","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/a997dd615598650934f0b785cbe8a6468ea63481"},{"sha":"31a2de86d9034def9c58ef7f3d3dcae3d4dafd6f","author":{"email":"50f957e7ebf7b4286b7f73838f5eec431c788506@apache.org","name":"twalthr"},"message":"[FLINK-2961] [table] Add support for basic type Date in Table API\n\nFix nullCheck enabled\n\nFix test\n\nTableConfig introduced\n\nImprovements and bug fixing\n\nThis closes #1322.","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/31a2de86d9034def9c58ef7f3d3dcae3d4dafd6f"},{"sha":"3e9d33ee5b15d20bf1d2ee757543806619997b49","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[FLINK-3075] Change Either creation method names and expose Right/Left classes\n\nCloses #1402","distinct":false,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/3e9d33ee5b15d20bf1d2ee757543806619997b49"},{"sha":"209ae6c916e1bff7126b074dfe831bbc7b113e4a","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-3061] Properly fail Kafka Consumer if broker is not available\n\nThis closes #1395","distinct":true,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/209ae6c916e1bff7126b074dfe831bbc7b113e4a"},{"sha":"20ebad048d3b4621a6e801a4d24a15d4468f2ba6","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[FLINK-3088] [serialization] Fix copy method of TypeSerializer which use Kryo\n\nSome TypeSerializer, WritableSerializer, ValueSerializer, and AvroSerializer, and\ncomparators, WritableComparator and ValueComparator, use Kryo to copy records.\nIn case where the Kryo serializer cannot copy the record, the copy method fails.\nThis is however not necessary, because one can copy the element by serializing\nthe record to a byte array and deserializing it from this array. This PR adds\nthis behaviour to the respective classes.\n\nAdds KryoUtils tool with copy method to avoid code duplication\n\nThis closes #1415.\n\nAdds comments to KryoUtils functions","distinct":true,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/20ebad048d3b4621a6e801a4d24a15d4468f2ba6"},{"sha":"2b358cde0d232a3bfbc59fa9a6845b0c754f1704","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[tests] Activate ChaosMonkeyITCase","distinct":true,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/2b358cde0d232a3bfbc59fa9a6845b0c754f1704"},{"sha":"cf913476965051d2ca38f3e95a84246bb7de712e","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-3083] [docs] Add docs on how to configure streaming fault tolerance.\n\nThis closes #1413","distinct":true,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/cf913476965051d2ca38f3e95a84246bb7de712e"},{"sha":"b80ecfdc211e1e91d6ebc5b79e257901933a047d","author":{"email":"9bcb11ac70c2fc7872d9b58e21318011c5e228e2@gmail.com","name":"Sachin Goel"},"message":"[FLINK-2904] [web-dashboard] Fix truncation of task counts when the number is large.\n\nThis closes #1321","distinct":true,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/b80ecfdc211e1e91d6ebc5b79e257901933a047d"},{"sha":"6bac921445d8fdecc4951bd4b9342bce0994c5ba","author":{"email":"c31e8abd89d696a5d689fff5b6ae115532bc6875@apache.org","name":"zentol"},"message":"[FLINK-2351] [core] Remove IOFormat ConfigBuilders\n\nThis closes #1420","distinct":true,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/6bac921445d8fdecc4951bd4b9342bce0994c5ba"},{"sha":"80512229c487537e59688d35ffdfb10dc18a8ac9","author":{"email":"9bcb11ac70c2fc7872d9b58e21318011c5e228e2@gmail.com","name":"Sachin Goel"},"message":"[FLINK-3056] [web-dashboard] Represent bytes in more readable form.\n\nBytes are now displayed in the following fashion:\n  1. For [0, 1000) units, display three significant digits.\n  2. For [1000,1024) units, display 2 decimal points for the next higher unit.\nFor example, 1010 KB is displayed as 0.99 MB, 10 MB is displayed as 10.0 MB and 230 MB is displayed as such.\n\nThis closes #1419","distinct":true,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/80512229c487537e59688d35ffdfb10dc18a8ac9"},{"sha":"d5a6b13ab1ff6f42369b6b1cd2aad73bd6910362","author":{"email":"f55f5fad55aaea3a24db3b0da6267c06dda1c57a@apache.org","name":"Chiwan Park"},"message":"[FLINK-2950] [ml] [docs] Fix markdown rendering problem in SVM documentation\n\n  - Remove unnecessary indentation of table\n  - Fix wrong `strong` end tag\n  - Simplify lambda expression in map operation\n\nThis closes #1312","distinct":true,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/d5a6b13ab1ff6f42369b6b1cd2aad73bd6910362"},{"sha":"cd899f3be39c5f052a2a3e90771111d1a7df1d47","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[FLINK-2972] [JavaAPI] Remove Chill dependency from flink-java.\n\nThis closes #1331","distinct":true,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/cd899f3be39c5f052a2a3e90771111d1a7df1d47"},{"sha":"d1ea365ef1fa979d40532bf3f114fc03284164bc","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-3084] [streaming] FsStateBackend backs up very small state directly with the metadata.\n\nThis closes #1423","distinct":true,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/d1ea365ef1fa979d40532bf3f114fc03284164bc"},{"sha":"19b2a8e3e42a0a79aa074934bd2b58d680037a19","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[hotfix] Declare env and insertStatement transient in DbStateBackend","distinct":true,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/19b2a8e3e42a0a79aa074934bd2b58d680037a19"},{"sha":"5a3d0728f007e7c69ced1104ef754bb6f17047f7","author":{"email":"32df6fc0044be0eb6a4aec06ce5d377d80bbc050@gmail.com","name":"madhukar"},"message":"[FLINK-3092] [docs] Fix Scala API quick start word count example\n\nThis closes #1424.","distinct":true,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/5a3d0728f007e7c69ced1104ef754bb6f17047f7"},{"sha":"31f6a744c78adcb4f702da3cbabe7d462a66184e","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[tests] Decrease verbosity of ChaosMonkeyITCase","distinct":true,"url":"https://api.github.com/repos/tillrohrmann/flink/commits/31f6a744c78adcb4f702da3cbabe7d462a66184e"}]}