{"push_id":2679644642,"size":13,"distinct_size":1,"ref":"refs/heads/stream-join-one-timer-per-element","head":"6a0d46231a4dce24233a754ce908c56acd473f85","before":"d0065a308bc4c537ea86c0ddfedebf83e99b9fb1","commits":[{"sha":"167be0a91d6f5863ecff04c1e13dfe60b11ae3b1","author":{"name":"Dawid Wysakowicz","email":"b92c3fa439edb8fc12fbf633311cd19b4e777d75@apache.org"},"message":"[FLINK-9366] DistributedCache works with Distributed File System\n\nThis closes #6107","distinct":false,"url":"https://api.github.com/repos/florianschmidt1994/flink/commits/167be0a91d6f5863ecff04c1e13dfe60b11ae3b1"},{"sha":"2fdc768edd7cd88ab4584f7d9072640ba77e1678","author":{"name":"minwenjun","email":"923a59dc6f4431f56e968db0a861ccf5bb4d1ff2@didichuxing.com"},"message":"[FLINK-9579][CEP]Remove unneeded clear on elementQueueState\n\nThis closes #6162","distinct":false,"url":"https://api.github.com/repos/florianschmidt1994/flink/commits/2fdc768edd7cd88ab4584f7d9072640ba77e1678"},{"sha":"4a0dc8273f422dbf28e105760b52bdcc3cffb8e7","author":{"name":"Yadan.JS","email":"9a27af7252130247133ff12a0e679a8ef1ca0120@yahoo.com"},"message":"[FLINK-9551][DOCS]FlinkCEP Scala Combining Patterns table has a missing pattern\n\nThis closes #6139","distinct":false,"url":"https://api.github.com/repos/florianschmidt1994/flink/commits/4a0dc8273f422dbf28e105760b52bdcc3cffb8e7"},{"sha":"7e0eafa74d81a805d1445fb74e967acaf455e967","author":{"name":"Stefan Richter","email":"9e3f93c9985d87dfa6d825f62ede58d002709f43@data-artisans.com"},"message":"[FLINK-9487][state] Prepare InternalTimerHeap for asynchronous snapshots\n\nThis closes #6159.","distinct":false,"url":"https://api.github.com/repos/florianschmidt1994/flink/commits/7e0eafa74d81a805d1445fb74e967acaf455e967"},{"sha":"ae9178fa0f93c67d081a3404c1088f3b2c494cc7","author":{"name":"Stefan Richter","email":"9e3f93c9985d87dfa6d825f62ede58d002709f43@data-artisans.com"},"message":"[hotfix][state] Introduce hard size limit for CopyOnWriteStateTable","distinct":false,"url":"https://api.github.com/repos/florianschmidt1994/flink/commits/ae9178fa0f93c67d081a3404c1088f3b2c494cc7"},{"sha":"0e9b066aaba405f58b807c5897213048cfa8319a","author":{"name":"sihuazhou","email":"be1c497c6dd72e15994cc4f4693c3c63d38b1a46@163.com"},"message":"[FLINK-9601][state] Make sure that the copied array in `CopyOnWriteStateTable#snapshotTableArrays()` is big enough to hold all (flattened) entries\n\nThis closes #6174.","distinct":false,"url":"https://api.github.com/repos/florianschmidt1994/flink/commits/0e9b066aaba405f58b807c5897213048cfa8319a"},{"sha":"0bdde8377c254195fe94709d639bf03f9bd77606","author":{"name":"Andrey Zagrebin","email":"a340fbdcc562bdf11acef14490b5725ba239619a@gmail.com"},"message":"[FLINK-9571] Repace StateBinder with internal backend-specific state factories\n\nThis closes #6173.","distinct":false,"url":"https://api.github.com/repos/florianschmidt1994/flink/commits/0bdde8377c254195fe94709d639bf03f9bd77606"},{"sha":"59a58e56cc2f5f1015244ef835a014e68675234f","author":{"name":"Florian Schmidt","email":"cf4554c7a85958995dd86b63b9de08529b054d60@icloud.com"},"message":"[FLINK-8982][e2e tests] Add E2E Tests for queryable state.\n\nAdds one test for normal execution and\none with a TM failure scenario.\n\nThis closes #5807.","distinct":false,"url":"https://api.github.com/repos/florianschmidt1994/flink/commits/59a58e56cc2f5f1015244ef835a014e68675234f"},{"sha":"055a81506402a509099c32f4b1c14670ba9279da","author":{"name":"Florian Schmidt","email":"cf4554c7a85958995dd86b63b9de08529b054d60@icloud.com"},"message":"[FLINK-8479] Implement TimeBoundedStreamJoinOperator\n\nThis operator is the basis for performing an inner join on two\nstreams using a time criteria defined as a lower and upper bound","distinct":false,"url":"https://api.github.com/repos/florianschmidt1994/flink/commits/055a81506402a509099c32f4b1c14670ba9279da"},{"sha":"d8928c39ef18657d6636603fe49e29348220c687","author":{"name":"Florian Schmidt","email":"cf4554c7a85958995dd86b63b9de08529b054d60@icloud.com"},"message":"Add missing check for stream side","distinct":false,"url":"https://api.github.com/repos/florianschmidt1994/flink/commits/d8928c39ef18657d6636603fe49e29348220c687"},{"sha":"f1e544ea8018499006e3e752bd1fa586450eadca","author":{"name":"Florian Schmidt","email":"cf4554c7a85958995dd86b63b9de08529b054d60@icloud.com"},"message":"Fix accidentally introduced error","distinct":false,"url":"https://api.github.com/repos/florianschmidt1994/flink/commits/f1e544ea8018499006e3e752bd1fa586450eadca"},{"sha":"4cbb4d3a487c98bf7a4826aba16f7bcf2b1fa539","author":{"name":"Florian Schmidt","email":"cf4554c7a85958995dd86b63b9de08529b054d60@icloud.com"},"message":"[FLINK-8480][DataStream] Add java api for timebounded stream joins\n\nThis commit adds a java implementation for timebounded stream joins.\nThe usage looks roughly like the following:\n\n```java\nstreamOne\n\t.join(streamTwo)\n\t.where(new Tuple2KeyExtractor())\n\t.equalTo(new Tuple2KeyExtractor())\n\t.between(Time.milliseconds(0), Time.milliseconds(1))\n\t.process(new CombineToStringJoinFunction())\n\t.addSink(new ResultSink());\n```\n\nThis change adds the functionality in JoinedStreams.java and adds\nintegration tests in TimeboundedJoinITCase.java","distinct":false,"url":"https://api.github.com/repos/florianschmidt1994/flink/commits/4cbb4d3a487c98bf7a4826aba16f7bcf2b1fa539"},{"sha":"6a0d46231a4dce24233a754ce908c56acd473f85","author":{"name":"Florian Schmidt","email":"cf4554c7a85958995dd86b63b9de08529b054d60@icloud.com"},"message":"Add version with one timer per elemen","distinct":true,"url":"https://api.github.com/repos/florianschmidt1994/flink/commits/6a0d46231a4dce24233a754ce908c56acd473f85"}]}
{"actor":{"display_login":"florianschmidt1994"}}