{"push_id":1410766573,"size":216,"distinct_size":0,"ref":"refs/heads/master","head":"13ebb36bb6c7fbe591d9e7834a2fc34d8469bc00","before":"6731ec1e48d0a0092dd2330adda73bcf37fda8d7","commits":[{"sha":"1dda3ad009667697a620359e997e83a5ba2447dd","author":{"name":"twalthr","email":"3b937f4608445891ad01c55897b04eb069f446af@apache.org"},"message":"[FLINK-4793] [types] Improve lambda constructor reference handling\n\nThis closes #2621.","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/1dda3ad009667697a620359e997e83a5ba2447dd"},{"sha":"7b79c8b52832e3a99e565e865831b56615416ae7","author":{"name":"Robert Metzger","email":"0267b3fb5eee07973aded5cd271875b0cce4ade0@apache.org"},"message":"[FLINK-3706] Fix YARN test instability\n\nThe most important change in this commit is that the `YarnTestBase.Runner` doesn't do \"try {} catch (Throwable t) { fail(t); }\" anymore, which doesn't lead to a test failure, because its called outside the main thread.\nWith the change, all throwables are reported back to the main thread and fail the test there properly (many YARN tests benefit from this change).\n\nThis closes #2622","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/7b79c8b52832e3a99e565e865831b56615416ae7"},{"sha":"15df71ba9b4d6c630a09b1b46d5419b821464d97","author":{"name":"Maximilian Michels","email":"0babbab6c2ab1e494e95176e73e7efe04dd4b11a@apache.org"},"message":"[FLINK-4799] re-add 'build-target' symlink on Unix systems\n\nThis adds back the link 'build-target' which points to the final build\nassembly in 'flink-dist/target/'.\n\nThis closes #2620","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/15df71ba9b4d6c630a09b1b46d5419b821464d97"},{"sha":"744f8ebb66b2a7288942be139cd7a7e6d1170c80","author":{"name":"Robert Metzger","email":"0267b3fb5eee07973aded5cd271875b0cce4ade0@apache.org"},"message":"[hotfix][kafka] Undo DataGenerators changes (use inline kafka producer again","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/744f8ebb66b2a7288942be139cd7a7e6d1170c80"},{"sha":"3d5bca0abcb6071c2eedfedce36b883a6f605687","author":{"name":"Robert Metzger","email":"0267b3fb5eee07973aded5cd271875b0cce4ade0@apache.org"},"message":"[hotfix][kafka] Backport Kafka09FetcherTest for Kafka010\n\nThis closes #2627","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/3d5bca0abcb6071c2eedfedce36b883a6f605687"},{"sha":"c7d1a3b8dfe8d31c77e2ba0afb8bf71674134427","author":{"name":"twalthr","email":"3b937f4608445891ad01c55897b04eb069f446af@apache.org"},"message":"[FLINK-4791] [table] Fix issues caused by expression reduction","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/c7d1a3b8dfe8d31c77e2ba0afb8bf71674134427"},{"sha":"fd410d9f6d1c8d53fb721752528ebd77fd78db57","author":{"name":"Ufuk Celebi","email":"78b56ba69f8ee462da352d0ec4ccfd5661b9c331@apache.org"},"message":"[FLINK-4512] [FLIP-10] Add option to persist periodic checkpoints\n\n[FLINK-4509] [FLIP-10] Specify savepoint directory per savepoint\n[FLINK-4507] [FLIP-10] Deprecate savepoint backend config\n\nThis closes #2608.","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/fd410d9f6d1c8d53fb721752528ebd77fd78db57"},{"sha":"5783671c2f30228a2d5b5b7bf09b762ae41db8e2","author":{"name":"Ufuk Celebi","email":"78b56ba69f8ee462da352d0ec4ccfd5661b9c331@apache.org"},"message":"[FLINK-4717] Add CancelJobWithSavepoint\n\n- Adds CancelJobWithSavepoint message, which triggers a savepoint\n  before cancelling the respective job.\n- Adds -s [targetDirectory] option to CLI cancel command:\n    * bin/flink cancel <jobID> (regular cancelling)\n    * bin/flink cancel -s <jobID> (cancel with savepoint to default dir)\n    * bin/flink cancel -s <targetDir> <jobID> (cancel with savepoint to targetDir)\n\nThis closes #2609.","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/5783671c2f30228a2d5b5b7bf09b762ae41db8e2"},{"sha":"f6d8668175fb94f338037fd1ab40d2a2e344d097","author":{"name":"Stephan Ewen","email":"aca661980edc82bcd0d553be7ee17e3d62509c0a@apache.org"},"message":"[FLINK-4373] [cluster management] Introduce AllocationID, ResourceProfile, and AllocatedSlot\n\nThese classes are introduced as part of the cluster management rework.\n\nThis closes #2630","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/f6d8668175fb94f338037fd1ab40d2a2e344d097"},{"sha":"21e8e2dcf77f9d0dc3a74204626b776d87a9cd15","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-4720] Implement archived ExecutionGraph\n\nThis closes #2577.","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/21e8e2dcf77f9d0dc3a74204626b776d87a9cd15"},{"sha":"9948d48443460a881eb79983f586c7bd18201674","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-4774] [metrics] Fix scope concatenation in QueryScopeInfo\n\nThis closes #2613.","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/9948d48443460a881eb79983f586c7bd18201674"},{"sha":"a648f88fbc4780db99ecef8729d4cd7d29656dbd","author":{"name":"hzyuemeng1","email":"346bfcff93506cd15958fb7ba8a4b5e9c530210e@corp.netease.com"},"message":"[FLINK-4827] [docs] Fix scala Streaming Table example\n\nThis closes #2632.","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/a648f88fbc4780db99ecef8729d4cd7d29656dbd"},{"sha":"a612b9966f3ee020a5721ac2f039a3633c40146c","author":{"name":"Robert Metzger","email":"0267b3fb5eee07973aded5cd271875b0cce4ade0@apache.org"},"message":"[FLINK-3660] Measure latency and exposes them via a metric\n\nThis commit adds the initial runtime support for measuring latency of records going through the system.\n\nI therefore introduced a new StreamElement, called a LatencyMarker.\nSimilar to Watermarks, LatencyMarkers are emitted from the sources at an configured interval. The default value for the interval is 2000 ms. The emission of markers can be disabled by setting the interval to 0. LatencyMarkers can not \"overtake\" regular elements. This ensures that the measured latency approximates the end-to-end latency of regular stream elements.\n\nRegular operators (excluding those participating in iterations) forward latency markers if they are not a sink.\nOperators with many outputs randomly select one to forward the maker to. This ensures that every marker exists only once in the system, and that repartition steps are not causing an explosion in the number of transferred markers.\nIf an operator is a sink, it will maintain the last 512 latencies from each known source instance.\nThe min/max/mean/p50/p95/p99 of each known source is reported using a special LatencyGauge from the sink (every operator can be a sink, if it doesn't have any outputs).\n\nThis commit does not visualize the latency in the web interface.\nAlso, there is currently no mechanism to ensure that the system clocks are in-sync, so the latency measurements will be inaccurate if the hardware clocks are not correct.\n\nThis closes #2386","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/a612b9966f3ee020a5721ac2f039a3633c40146c"},{"sha":"436c3335b83979b9a278e480b3278bed71081322","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[hotfix] Fix ArchivedExecutionGraphTest","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/436c3335b83979b9a278e480b3278bed71081322"},{"sha":"5dc624bf816093ca0c240c7bcfe37841605ce592","author":{"name":"Robert Metzger","email":"0267b3fb5eee07973aded5cd271875b0cce4ade0@apache.org"},"message":"[FLINK-3660][hotfix] Add missing default value in ConfigConstants","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/5dc624bf816093ca0c240c7bcfe37841605ce592"},{"sha":"85b53444a852027714904a050a68489740b7f2f8","author":{"name":"Anton Mushin","email":"0205a005e8991024a2457bad8ccb40303432db0b@epam.com"},"message":"[FLINK-4564] [metrics] Configurable delimiter per reporter\n\nThis closes #2517.","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/85b53444a852027714904a050a68489740b7f2f8"},{"sha":"5bd47012e50516d45a6b50d47f347e6802dfde4c","author":{"name":"Vijay Srinivasaraghavan","email":"eef90b07b4e8760caaf19cae9551e0f2eba28897@emc.com"},"message":"[FLINK-3932] Added ZK ACL configuration for secure cluster setup\n\nThis closes #2589.","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/5bd47012e50516d45a6b50d47f347e6802dfde4c"},{"sha":"6d4dd75859aa5e78a20dc3a9492391f1c7f7ca7a","author":{"name":"Vijay Srinivasaraghavan","email":"eef90b07b4e8760caaf19cae9551e0f2eba28897@emc.com"},"message":"[FLINK-4667] Fix for using correct ZK namespace in Yarn deployment","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/6d4dd75859aa5e78a20dc3a9492391f1c7f7ca7a"},{"sha":"a2e999b960319f51b34f3dfc68d29121eca5ae60","author":{"name":"Maximilian Michels","email":"0babbab6c2ab1e494e95176e73e7efe04dd4b11a@apache.org"},"message":"[FLINK-4667] add import for config entry","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/a2e999b960319f51b34f3dfc68d29121eca5ae60"},{"sha":"a85d8e57a3501e39284e24221b50c6222e85c06c","author":{"name":"Kirill Morozov","email":"a067543f8a7c029a6ff64a8ecf307eff9a4af61f@epam.com"},"message":"[FLINK-4506] [DataSet] Fix documentation of CsvOutputFormat about incorrect default of allowNullValues\n\n- Add test case for CsvOutputFormat\n\nThis closes #2477\nThis closes #2631","distinct":false,"url":"https://api.github.com/repos/senorcarbone/flink/commits/a85d8e57a3501e39284e24221b50c6222e85c06c"}]}
{"actor":{"display_login":"senorcarbone"}}