{"push_id":884042740,"size":52,"distinct_size":52,"ref":"refs/heads/master","head":"3e9d33ee5b15d20bf1d2ee757543806619997b49","before":"68a69c76ae66908658bed17a95dda7b74bc72675","commits":[{"sha":"cd7963cbe4286777c28d99d750259eef6ea67238","author":{"email":"f55f5fad55aaea3a24db3b0da6267c06dda1c57a@apache.org","name":"Chiwan Park"},"message":"[FLINK-2947] [scala shell] Add color support to Scala Shell","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/cd7963cbe4286777c28d99d750259eef6ea67238"},{"sha":"601e8c607d974ef96e45d1dc3d2be367f5ddfb32","author":{"email":"d22fe4c37466fd2128f6ceeb947bbfb4c52e5900@retresco.de","name":"Martin Liesenberg"},"message":"[FLINK-2017] Add predefined required parameters to ParameterTool\n\n- Add RequiredParameters class to handle required parameters in UDFs which can be checked\n  and validated against the parameters extracted in ParameterTool\n- A required parameter is represented by an Option which has by default only a name and can\n  be extended to include possible values, a type, a default value\n- Any validation failure will throw a RequiredParametersException\n\nThis closes #1097","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/601e8c607d974ef96e45d1dc3d2be367f5ddfb32"},{"sha":"8cabe67e7fb0eb40e7b58cfd52b8e1b0e5bc5268","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[FLINK-3020][streaming] set number of task slots to maximum parallelism in local execution\n\nThis closes #1360.","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/8cabe67e7fb0eb40e7b58cfd52b8e1b0e5bc5268"},{"sha":"ad6f826584be7527c58e2126e2828f82afc97875","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[FLINK-2916] [streaming] Expose operator and task information to StateBackend","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/ad6f826584be7527c58e2126e2828f82afc97875"},{"sha":"75a7c4b109be68c02b1c7733310f4f9000ad8bf6","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[FLINK-2924] [streaming] Out-of-core state backend for JDBC databases","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/75a7c4b109be68c02b1c7733310f4f9000ad8bf6"},{"sha":"347e6f7560a78ad3b58ff274c212a9f32c5d88fd","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[FLINK-2924] [streaming] Improved sharding logic","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/347e6f7560a78ad3b58ff274c212a9f32c5d88fd"},{"sha":"c254bda3e84fcd9303f9a9e2a6f7a175d8e70d1e","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[FLINK-2924] [streaming] Use timestamps to store checkpoints so it supports job shutdown/restart","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/c254bda3e84fcd9303f9a9e2a6f7a175d8e70d1e"},{"sha":"43b8e57b82b4fb086a8b307c6ca3b4c2b8086532","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[FLINK-2924] [streaming] Improve compacting logic","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/43b8e57b82b4fb086a8b307c6ca3b4c2b8086532"},{"sha":"cd8be0b785722eae021ceaca8887025d6b61cf12","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[FLINK-2924] [streaming] Use short job id for table names","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/cd8be0b785722eae021ceaca8887025d6b61cf12"},{"sha":"db2a964a450c05cb2aad3843999d994e4b8e5ef5","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[FLINK-2924] [streaming] Execute compactions in background thread + keep connections alive on empty snapshots\n\nCloses #1305","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/db2a964a450c05cb2aad3843999d994e4b8e5ef5"},{"sha":"89b1d233254de024942c06700cedd86fff55970e","author":{"email":"6cd8718626a16063cc3afa941dc9715c0845c635@126.com","name":"gallenvara"},"message":"[FLINK-2956] [tests] Migrate integration tests for Table API","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/89b1d233254de024942c06700cedd86fff55970e"},{"sha":"85e7b2878eb50767ba64bbbd5794929d151f81ef","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-3045] Properly expose the key of a Kafka message\n\nThis closes #1385","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/85e7b2878eb50767ba64bbbd5794929d151f81ef"},{"sha":"4c46b2feee2c1ecda21e5ba62d02dfd7df73e256","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@informatik.hu-berlin.de","name":"mjsax"},"message":"[FLINK-2861] Fields grouping on split streams fails\n\nThis closes #1387","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/4c46b2feee2c1ecda21e5ba62d02dfd7df73e256"},{"sha":"f02369af7710412a49b566c4a96039f2aa39dfec","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[docs, setup] Add note about (task|job)manager scripts","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/f02369af7710412a49b566c4a96039f2aa39dfec"},{"sha":"f887ba81e986058308d1f56f7a6efed00166723c","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-3070] Add AsynchronousStateHandle\n\nThis extends StateHandle with a materialize() method. The asynchronous\nhandle represents state and can materialize it when required.","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/f887ba81e986058308d1f56f7a6efed00166723c"},{"sha":"a65bcef8cb38a02af61d43ceefba1f1104d28c3f","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[hotfix] fix shaded reference","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/a65bcef8cb38a02af61d43ceefba1f1104d28c3f"},{"sha":"54e642b31e615296ddf1e69ca9130b4cec24e292","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[docs, setup] Add missing parenthesis","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/54e642b31e615296ddf1e69ca9130b4cec24e292"},{"sha":"66b5def320054776f09fb8a7f9b77be6f1572ae2","author":{"email":"62c32629769998ef6046bdefb2e2837613227b91@apache.org","name":"smarthi"},"message":"[streaming] [ml] Code cleanup: unused imports, fix javadocs\n\nThis closes #1391.","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/66b5def320054776f09fb8a7f9b77be6f1572ae2"},{"sha":"d2b4391f4e42a96a8b3c852e303aba170de15727","author":{"email":"028f9aa649c9e6daa8714de7f07f59278ef37cf7@mailbox.org","name":"Martin Junghanns"},"message":"[FLINK-3064] [core] Add size check in GroupReduceOperatorBase\n\nThis closes #1396.","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/d2b4391f4e42a96a8b3c852e303aba170de15727"},{"sha":"5558e7688e777853a23d94edc31971aa1e230d1e","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-2996] Introduce configuration parameter for BlobServer port\n\nThis closes #1394","distinct":true,"url":"https://api.github.com/repos/radicalbit/flink/commits/5558e7688e777853a23d94edc31971aa1e230d1e"}]}