{"push_id":2336486319,"size":76,"distinct_size":76,"ref":"refs/heads/master","head":"ebfa0bdf52798cb63c3d6236ac18b7ef1ea7406d","before":"8395508b0401353ed07375e22882e7581d46ac0e","commits":[{"sha":"9628dc8917b2f69bb04119c1d41932076632de01","author":{"name":"kkloudas","email":"1f09c57e6554e446feec7f25de5ccb0774f17620@gmail.com"},"message":"[FLINK-8456] Add Scala API for Connected Streams with Broadcast State.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/9628dc8917b2f69bb04119c1d41932076632de01"},{"sha":"dea4172604126fc40fc8fbf7f83a632733bd0dfb","author":{"name":"kkloudas","email":"1f09c57e6554e446feec7f25de5ccb0774f17620@gmail.com"},"message":"[FLINK-8597] Add examples for Connected Streams with Broadcast State.\n\nThis closes #5425.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/dea4172604126fc40fc8fbf7f83a632733bd0dfb"},{"sha":"bfe6f84cf1b99f1dfa801a1818fa51ccc7817c9b","author":{"name":"Stefan Richter","email":"f4fa93155523de454f7719daac3d15e33e599d43@data-artisans.com"},"message":"[hotfix] Move DataStreamUtils to the datastream API package so that we can actually use it to expose package-private constructors or methods for experimental features.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/bfe6f84cf1b99f1dfa801a1818fa51ccc7817c9b"},{"sha":"91eea376eee1ca2612b0f0603511b5eb52f11195","author":{"name":"Stefan Richter","email":"f4fa93155523de454f7719daac3d15e33e599d43@data-artisans.com"},"message":"[FLINK-8571] [DataStream] Introduce utility function that reinterprets a data stream as keyed stream\n\nThis closes #5424.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/91eea376eee1ca2612b0f0603511b5eb52f11195"},{"sha":"5fe31cbf26f35ae6921d543d362d2d9f006f45db","author":{"name":"Tzu-Li (Gordon) Tai","email":"365712edb57746e0418ca654594db9d64fc90658@apache.org"},"message":"[FLINK-7124] [flip6] Add test to verify rescaling JobGraphs works correctly\n\nThis commit adds two tests to verify behaviours of rescaling JobGraphs:\n1. JobGraphs can be consecutively rescaled to arbitrary valid DOPs\n2. Rescaling beyond max parallelism would fail\n\nThe second test, however, is temporarily disabled for now since it\ndoesn't properly fail.\n\nThis closes #4510.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/5fe31cbf26f35ae6921d543d362d2d9f006f45db"},{"sha":"aee578b14dab17d56e7ee6e08f02c9d858ebec5b","author":{"name":"Till Rohrmann","email":"9006f1940e337c648feb3df40b3beb29c822bbfc@apache.org"},"message":"[FLINK-7124] [flip6] Introduce parallelism <= max parallelism check into ExecutionJobVertex\n\nCheck that the parallelism is smaller than the max parallelism when creating an\nExecutionJobVertex.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/aee578b14dab17d56e7ee6e08f02c9d858ebec5b"},{"sha":"556ea8a71731218096f013c5b06af57fa6404560","author":{"name":"Tzu-Li (Gordon) Tai","email":"365712edb57746e0418ca654594db9d64fc90658@apache.org"},"message":"[hotfix] Refactor graph verification code in ExecutionGraphConstructionTest\n\nThe refactoring resuses utility methods in ExecutionGraphTestUtils to\nverify constructed ExecutionGraphs.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/556ea8a71731218096f013c5b06af57fa6404560"},{"sha":"f2ae2414d65ab2fbfa1efd60f69e243fbeeba118","author":{"name":"Xpray","email":"f321bc0ef7df9551eb665b34e79547ecd15f032b@gmail.com"},"message":"[FLINK-8617] [table] Fix code generation bug while accessing Map type\n\nThis closes #5438.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/f2ae2414d65ab2fbfa1efd60f69e243fbeeba118"},{"sha":"4c8851a3aa8d4154e88d8a19c93535ee9ac4a6a3","author":{"name":"Till Rohrmann","email":"9006f1940e337c648feb3df40b3beb29c822bbfc@apache.org"},"message":"[FLINK-8636] [flip6] Use TaskManagerServices to pass in services to TaskExecutor\n\nPass in the TaskExecutor services via the TaskManagerServices instead\nof individually.\n\nThis closes #5456.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/4c8851a3aa8d4154e88d8a19c93535ee9ac4a6a3"},{"sha":"1c02e1a43219890b4e9d7f2451f607a51a4ac348","author":{"name":"Till Rohrmann","email":"9006f1940e337c648feb3df40b3beb29c822bbfc@apache.org"},"message":"[hotfix] Simplify TaskExecutorTest to avoid Mockito","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/1c02e1a43219890b4e9d7f2451f607a51a4ac348"},{"sha":"02ea508736e06e08ff53921994b29ce8db0f5f50","author":{"name":"Piotr Nowojski","email":"b1f53f7d2aa8393aadf6e3a89582ddc2f03a19b5@gmail.com"},"message":"[hotfix][kafka-tests] Do not hide original exception in FlinkKafkaProducer011ITCase\n\nThis closes #5383.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/02ea508736e06e08ff53921994b29ce8db0f5f50"},{"sha":"0587bf830bd854537b678b3aac4187da44c1a64e","author":{"name":"ifndef-SleePy","email":"9db3ff97fdf6333e6bc2abd8aa1f441c01934102@gmail.com"},"message":"[FLINK-7871] [flip6] SlotPool should release unused slots to RM\n\nThis closes #5048.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/0587bf830bd854537b678b3aac4187da44c1a64e"},{"sha":"f429b4cdeef7cce07341c1d0e8cdf23a89399dc7","author":{"name":"Till Rohrmann","email":"9006f1940e337c648feb3df40b3beb29c822bbfc@apache.org"},"message":"[FLINK-7871] [flip6] Add ManualClock for SlotPool slot release tests","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/f429b4cdeef7cce07341c1d0e8cdf23a89399dc7"},{"sha":"023ab749cc2d82fcf729d3e3f8052c60280f0af3","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-8475][config][docs] Integrate Algorithm options\n\nThis closes #5460.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/023ab749cc2d82fcf729d3e3f8052c60280f0af3"},{"sha":"99c07d967a7a27ce06ded601cbc4c36d1b6702e2","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-8475][config][docs] Integrate Mesos options\n\nThis closes #5461.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/99c07d967a7a27ce06ded601cbc4c36d1b6702e2"},{"sha":"7910d0544b0dc74a0720055a4b38f10e63dc569c","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-8475][config][docs] Integrate netty options\n\nThis closes #5386.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/7910d0544b0dc74a0720055a4b38f10e63dc569c"},{"sha":"b5d7d7c6bf2b5c4ae157358aecb335a7c06dd41b","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-8475][config][docs] Integrate optimizer options\n\nThis closes #5387.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/b5d7d7c6bf2b5c4ae157358aecb335a7c06dd41b"},{"sha":"00cae7089ff698f23644169ccdb30f100aeb1545","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-8475][config][docs] Integrate REST options\n\nThis closes #5389.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/00cae7089ff698f23644169ccdb30f100aeb1545"},{"sha":"a8f64fb43ab4d3820b10b546a660d2767577a4f9","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-8475][config][docs] Integrate SlotManager options\n\nThis closes #5390.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/a8f64fb43ab4d3820b10b546a660d2767577a4f9"},{"sha":"10ad8c34d6c88d44e39428f0eea49e54f76fd7fc","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-8475][config][docs] Integrate BlobServer options\n\nThis closes #5391.","distinct":true,"url":"https://api.github.com/repos/zzcclp/flink/commits/10ad8c34d6c88d44e39428f0eea49e54f76fd7fc"}]}
{"actor":{"display_login":"zzcclp"}}