{"push_id":1201940544,"size":31,"distinct_size":31,"ref":"refs/heads/remove_recovery_timestamp","head":"116321241923194e9fa6db556681b333197fceed","before":"f91093ce24bf2a65deb8e1adc10c8cee487f6c93","commits":[{"sha":"221ab8ee97d2f46934839f44f33aaaa6c7e1edc7","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-4116] Metrics documentation","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/221ab8ee97d2f46934839f44f33aaaa6c7e1edc7"},{"sha":"9178076db2ba352b25c541b0bf3ec4504ef0ba6d","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-4116][metrics] Move config keys to ConfigConstants\n\nThis closes #2158","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/9178076db2ba352b25c541b0bf3ec4504ef0ba6d"},{"sha":"8f6876218bb1335e95ab04fc608ce21959889e57","author":{"name":"Ivan Mushketyk","email":"410d03eaf45830a43178c64b24c4886293e6ac82@gmail.com"},"message":"[FLINK-4096] Ensure JarOutputStream is always closed\n\nThis closes #2172","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/8f6876218bb1335e95ab04fc608ce21959889e57"},{"sha":"20aecf033ab98aa57032081a40e2f6e5303b20d7","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[hotfix][metrics] Remove leftover comment Registry","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/20aecf033ab98aa57032081a40e2f6e5303b20d7"},{"sha":"da9a16d5b0d958fa8464d268a6c59a84ef22f676","author":{"name":"smarthi","email":"460fb680219190d7266e67382bd0cb7298d502a9@apache.org"},"message":"[hotfix] fix errors and formatting in NiFi documentation\n\nThis closes #2224","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/da9a16d5b0d958fa8464d268a6c59a84ef22f676"},{"sha":"5df0b2759eb7bd8a7fa0f056ffd8d3d97bd712d7","author":{"name":"Jiri Simsa","email":"f46f405b027da11dbce24f65313801d55bca3a88@gmail.com"},"message":"[FLINK-4185] Reflecting rename from Tachyon to Alluxio.\n\nThis closes #2222","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/5df0b2759eb7bd8a7fa0f056ffd8d3d97bd712d7"},{"sha":"97533939596c90fab69e2b4000846fc588f2a07b","author":{"name":"Ivan Mushketyk","email":"410d03eaf45830a43178c64b24c4886293e6ac82@gmail.com"},"message":"[FLINK-3943] [table] Add support for EXCEPT operator\n\nThis closes #2169.","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/97533939596c90fab69e2b4000846fc588f2a07b"},{"sha":"36aad48e75010f105101b28e25924ad91ce745df","author":{"name":"Robert Metzger","email":"0267b3fb5eee07973aded5cd271875b0cce4ade0@apache.org"},"message":"[FLINK-4157] Catch Kafka metrics serialization exceptions\n\nThis closes #2206","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/36aad48e75010f105101b28e25924ad91ce745df"},{"sha":"81cf2296683a473db4061dd3bed0aeb249e05058","author":{"name":"Greg Hogan","email":"ab3bf20a456957ab3c21b104b37d8a70f0061e3c@greghogan.com"},"message":"[FLINK-4154] [core] Correction of murmur hash breaks backwards compatibility\n\nRevert \"[FLINK-3623] [runtime] Adjust MurmurHash Algorithm\"\n\nThis reverts commit 641a0d436c9b7a34ff33ceb370cf29962cac4dee.\n\nThis closes #2223","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/81cf2296683a473db4061dd3bed0aeb249e05058"},{"sha":"a7274d5661421a66dcb998efd72b547301e1dc0f","author":{"name":"Michal Fijolek","email":"dd677935808b9f04da46574170d344f277479578@gmail.com"},"message":"[FLINK-3190] failure rate restart strategy\n\nAdd toString method to Time\n\nReintroduce org.apache.flink.streaming.api.windowing.time.Time for backwards compatibility\n\nRemove Duration from FailureRateRestarStrategy\n\nThis closes #1954.","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/a7274d5661421a66dcb998efd72b547301e1dc0f"},{"sha":"662b4586856379f9baf19862721ad99a20e74d13","author":{"name":"Robert Metzger","email":"0267b3fb5eee07973aded5cd271875b0cce4ade0@apache.org"},"message":"[FLINK-4191] Expose shard information in kinesis deserialization schema\n\nThis closes #2225","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/662b4586856379f9baf19862721ad99a20e74d13"},{"sha":"f0387aca4eb05c19e7cf37edd1701b151f11d637","author":{"name":"Gordon Tai","email":"2aa2e9453ac5de74a849ef43e1c604c0555ddce5@vm5.com"},"message":"[FLINK-4018][kinesis-connector] Add configuration for idle time between get requests to Kinesis shards\n\nThis closes #2071","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/f0387aca4eb05c19e7cf37edd1701b151f11d637"},{"sha":"971dcc5dec802bea7f258781da111321167fb0e5","author":{"name":"Robert Metzger","email":"0267b3fb5eee07973aded5cd271875b0cce4ade0@apache.org"},"message":"[hotfix][docs] Add note about Kinesis producer limitations\n\nThis closes #2229","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/971dcc5dec802bea7f258781da111321167fb0e5"},{"sha":"1b327f1ae7d078e22700729524e374b449b0f209","author":{"name":"twalthr","email":"3b937f4608445891ad01c55897b04eb069f446af@apache.org"},"message":"[FLINK-3916] [table] Allow generic types passing the Table API\n\nThis closes #2197.","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/1b327f1ae7d078e22700729524e374b449b0f209"},{"sha":"cc9ee2cc37ed0c7a7f9b0c50cf5edca63e289e1a","author":{"name":"Till Rohrmann","email":"9006f1940e337c648feb3df40b3beb29c822bbfc@apache.org"},"message":"[hotfix] [execution graph] Null restart strategy field in ExecutionGraph when archiving","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/cc9ee2cc37ed0c7a7f9b0c50cf5edca63e289e1a"},{"sha":"508965e69cfb99724b69f1e5dc59e5f5d5a70315","author":{"name":"twalthr","email":"3b937f4608445891ad01c55897b04eb069f446af@apache.org"},"message":"[FLINK-4111] [table] Flink Table & SQL doesn't work in very simple example\n\nThis closes #2209.","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/508965e69cfb99724b69f1e5dc59e5f5d5a70315"},{"sha":"5c2da21f25741502dd8ca64ce9d314a1ebea1441","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-4123] Cassandra sink checks for exceptions in ack phase\n\nadd serialVersionUID\n\nswitch to AtomicReference\n\nwait-notify\n\ndisable logging\n\nadd test case for leaving ackPhaseLoopOnException\n\nprevent infinite loop in test\n\nThis closes #2183.","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/5c2da21f25741502dd8ca64ce9d314a1ebea1441"},{"sha":"74b09ce0db4d24a0ac25de2ecac391fdf8bd5a90","author":{"name":"Till Rohrmann","email":"9006f1940e337c648feb3df40b3beb29c822bbfc@apache.org"},"message":"[FLINK-4123] [cassandra] Fix concurrency issue in CassandraTupleWriteAheadSink\n\nThe updatesCount variable in the CassandraTupleWriteAheadSink.sendValues did not have\nguaranteed visibility. Thus, it was possible that the callback thread would read an\noutdated value for updatesCount, resulting in a deadlock. Replacing IntValue updatesCount\nwith AtomicInteger updatesCount fixes this issue.\n\nFurthermore, the PR hardens the CassandraTupleWriteAheadSinkTest which could have failed\nwith a NPE if the callback runnable was not set in time.","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/74b09ce0db4d24a0ac25de2ecac391fdf8bd5a90"},{"sha":"6b7bb7614848303d31811496fcb7107a78d448c3","author":{"name":"Robert Metzger","email":"0267b3fb5eee07973aded5cd271875b0cce4ade0@apache.org"},"message":"[FLINK-4127] Check API compatbility for 1.1 in flink-core\n\nThis closes #2177","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/6b7bb7614848303d31811496fcb7107a78d448c3"},{"sha":"435ffd9c06c435af382323963cd04a850e0148de","author":{"name":"Stefan Richter","email":"f4fa93155523de454f7719daac3d15e33e599d43@data-artisans.com"},"message":"[FLINK-4200] [Kafka Connector] Kafka consumers logs the offset from which they restore\n\nThis closes #2230","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/435ffd9c06c435af382323963cd04a850e0148de"}]}
{"actor":{"display_login":"StephanEwen"}}