{"push_id":577153114,"size":16,"distinct_size":16,"ref":"refs/heads/exactly-once","head":"ce8495093848bf2d61740d3efb443ae6505ea295","before":"640bbf606060b2129ff8ccd45db2a49bb3fe72bd","commits":[{"sha":"621431d402163053afbfe82a49e95be0a41d4e22","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"Add AbstractReader tests","distinct":true,"url":"https://api.github.com/repos/mbalassi/flink/commits/621431d402163053afbfe82a49e95be0a41d4e22"},{"sha":"5a27a28cf6802bbd247c7f2803e80b22e76ca26a","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"Forward buffer notifications at union input gate listener","distinct":true,"url":"https://api.github.com/repos/mbalassi/flink/commits/5a27a28cf6802bbd247c7f2803e80b22e76ca26a"},{"sha":"e9a8f6617ff2f124383ef90a57de6198bbfb2755","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"Initial refactoring InputGate <=> BufferReader [ci skip]","distinct":true,"url":"https://api.github.com/repos/mbalassi/flink/commits/e9a8f6617ff2f124383ef90a57de6198bbfb2755"},{"sha":"19da51f97b6223f84d7b6855f685e465384a0bfa","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[streaming] Initial implementations for handling superstep events","distinct":true,"url":"https://api.github.com/repos/mbalassi/flink/commits/19da51f97b6223f84d7b6855f685e465384a0bfa"},{"sha":"1b57dcc77fdc4b770a965d3f6f33de2ccf6dd482","author":{"email":"5c0368c5ea0c499c138380b3bfb02f5776cce689@gmail.com","name":"Paris Carbone"},"message":"Initial barrier FT logic added in runtime","distinct":true,"url":"https://api.github.com/repos/mbalassi/flink/commits/1b57dcc77fdc4b770a965d3f6f33de2ccf6dd482"},{"sha":"d74bb467eb1362d40e9ca862d3a2b3c1e11c5355","author":{"email":"5c0368c5ea0c499c138380b3bfb02f5776cce689@gmail.com","name":"Paris Carbone"},"message":"FT work in progress","distinct":true,"url":"https://api.github.com/repos/mbalassi/flink/commits/d74bb467eb1362d40e9ca862d3a2b3c1e11c5355"},{"sha":"b3eb01a31a52f48e293a10d7a3ff5702721a78ed","author":{"email":"5c0368c5ea0c499c138380b3bfb02f5776cce689@gmail.com","name":"Paris Carbone"},"message":"FT - JobManager fixes","distinct":true,"url":"https://api.github.com/repos/mbalassi/flink/commits/b3eb01a31a52f48e293a10d7a3ff5702721a78ed"},{"sha":"6f5eb825c2393baaf4c3b29f621c5ce4dc3237ee","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[streaming] BufferReader streaming superstep barrier handling","distinct":true,"url":"https://api.github.com/repos/mbalassi/flink/commits/6f5eb825c2393baaf4c3b29f621c5ce4dc3237ee"},{"sha":"4111cfbddc7ff8a8ee992de623dca66a8f3f5000","author":{"email":"5c0368c5ea0c499c138380b3bfb02f5776cce689@gmail.com","name":"Paris Carbone"},"message":"[streaming] FT superstep acks from vertices added","distinct":true,"url":"https://api.github.com/repos/mbalassi/flink/commits/4111cfbddc7ff8a8ee992de623dca66a8f3f5000"},{"sha":"64b097e32706b1055f01beccc30a697da7c2efb0","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"cleanup","distinct":true,"url":"https://api.github.com/repos/mbalassi/flink/commits/64b097e32706b1055f01beccc30a697da7c2efb0"},{"sha":"bde5f03f901741e666d3f2fe5839fab26f5e981d","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"several fixes","distinct":true,"url":"https://api.github.com/repos/mbalassi/flink/commits/bde5f03f901741e666d3f2fe5839fab26f5e981d"},{"sha":"f37e5ab5a91bc7b16b4c1048fcf1ca3902f75149","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"cleanup","distinct":true,"url":"https://api.github.com/repos/mbalassi/flink/commits/f37e5ab5a91bc7b16b4c1048fcf1ca3902f75149"},{"sha":"35ee47a36c3fe0f729f0ad6aa4403dc115b8c548","author":{"email":"5c0368c5ea0c499c138380b3bfb02f5776cce689@gmail.com","name":"Paris Carbone"},"message":"[streaming] temp fix for potential deadlock during the first barrier (till removing blocking RPCs)","distinct":true,"url":"https://api.github.com/repos/mbalassi/flink/commits/35ee47a36c3fe0f729f0ad6aa4403dc115b8c548"},{"sha":"7980fd561295e9353f49ce079dbac2f3095b8e90","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"rebase fix","distinct":true,"url":"https://api.github.com/repos/mbalassi/flink/commits/7980fd561295e9353f49ce079dbac2f3095b8e90"},{"sha":"1b93a8beafa9f7b823ffbe15b4a73a91bc243e16","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"Fix after rebase","distinct":true,"url":"https://api.github.com/repos/mbalassi/flink/commits/1b93a8beafa9f7b823ffbe15b4a73a91bc243e16"},{"sha":"ce8495093848bf2d61740d3efb443ae6505ea295","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"Moved barrier logic from BufferReader to AbstractRecordReader","distinct":true,"url":"https://api.github.com/repos/mbalassi/flink/commits/ce8495093848bf2d61740d3efb443ae6505ea295"}]}