{"push_id":874592642,"size":11,"distinct_size":9,"ref":"refs/heads/kafka_kv","head":"6d01092c2beafaf330fd3ffa9de7182fc431bdc3","before":"def0dc776cb1e4c1daec9b8f6862907a9d45dc36","commits":[{"sha":"8dc70f2e770ac1c355869f5e0b5e23379b1ed76f","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[FLINK-3052] [optimizer] Fix instantiation of bulk iteration candidates\n\nWhen a candidate for a bulk iteration is instantiated, then the optimizer creates candidates\nfor the step function. It is then checked that there exists a candidate solution for the step\nfunction whose properties met the properties of the input to the bulk iteration. Sometimes\nit is necessary to add a no-op plan node to the end of the step function to generate the\ncorrect properties. These new candidates have to be added to the final set of the accepted\ncandidates.\n\nThis commit adds that these new candidates are properly added to the set of accepted candidates.\n\nFix test and add new iteration tests\n\nAdd predecessor operator and dynamic path information to no op operator in bulk iterations\n\nThis closes #1388.","distinct":false,"url":"https://api.github.com/repos/rmetzger/flink/commits/8dc70f2e770ac1c355869f5e0b5e23379b1ed76f"},{"sha":"5864e4fd4368f1af6e1bc623c91b8e719693471d","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-2974] Add periodic offset committer for Kafka when checkpointing is disabled\n\nThis closes #1341","distinct":false,"url":"https://api.github.com/repos/rmetzger/flink/commits/5864e4fd4368f1af6e1bc623c91b8e719693471d"},{"sha":"a7111cdd0ef71afa902474240f46cd14758a11d4","author":{"email":"62c32629769998ef6046bdefb2e2837613227b91@apache.org","name":"smarthi"},"message":"[doc] Fix Documentation formatting for recently added ExecutionEnvironment.readSequenceFile()\n\nThis closes #1389.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/a7111cdd0ef71afa902474240f46cd14758a11d4"},{"sha":"09433032d8ecb13c66204d8912225af919577b4e","author":{"email":"f55f5fad55aaea3a24db3b0da6267c06dda1c57a@apache.org","name":"Chiwan Park"},"message":"[FLINK-2860] [ml] [docs] Remove an undefined argument in FlinkML documentation\n\nThis closes #1310.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/09433032d8ecb13c66204d8912225af919577b4e"},{"sha":"8801cbcf7667f514f6f733901e0b0e8cb50472ad","author":{"email":"8ec607a1787e1578c3c79b992940048922aa4627@apache.org","name":"Jun Aoki"},"message":"[FLINK-3009] Add dockerized jekyll environment\n\nThis is not to fulfill what FLINK-3009 is originally asking,\nbut I'm piggybacking to contribute a docker environment with jekyll\nso that users won't have to deal with environment versions.\n\nAuthor: Jun Aoki <jaoki@apache.org>\nAuthor: jaoki <jaoki@apache.org>\n\nCloses #1363 from jaoki/dockerized-docgen and squashes the following commits:\n\n7bf3661 [Jun Aoki] Added apache label\n36869e7 [jaoki] [FLINK-3009] Add dockerized jekyll environment","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/8801cbcf7667f514f6f733901e0b0e8cb50472ad"},{"sha":"1600fe2c2522c050068d6567c5a5e0b291e4c54e","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[hotfix][docs] Fix default config value, highlight detail in config","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/1600fe2c2522c050068d6567c5a5e0b291e4c54e"},{"sha":"455009659b3b51677574ce6cd6c1ea071e09b8c4","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-3045] Properly expose the key of a Kafka message","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/455009659b3b51677574ce6cd6c1ea071e09b8c4"},{"sha":"13a6b994e6a4da6e7bdd1409d4fd251884c25e6a","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"wip","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/13a6b994e6a4da6e7bdd1409d4fd251884c25e6a"},{"sha":"e945943c66ae77937790ea80d7a635c1e99a69c1","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"change the KeyedSerializationSchema interface","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/e945943c66ae77937790ea80d7a635c1e99a69c1"},{"sha":"6727eae3e596f634de0a48e1080098da915156d7","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"wip","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/6727eae3e596f634de0a48e1080098da915156d7"},{"sha":"6d01092c2beafaf330fd3ffa9de7182fc431bdc3","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"cleanup after rebase","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/6d01092c2beafaf330fd3ffa9de7182fc431bdc3"}]}