{"push_id":1378916493,"size":58,"distinct_size":21,"ref":"refs/heads/refactor-merging-window-set","head":"ca68d2e074eee66066377c3ebf69c0e15e9956d0","before":"649329c307cc0d9847774c7dfb6439f56ef574ae","commits":[{"sha":"2b31ec93a6245de2e30a6314a12fdbdcfb585440","author":{"name":"Stefan Richter","email":"f4fa93155523de454f7719daac3d15e33e599d43@data-artisans.com"},"message":"[FLINK-4843] Test for FsCheckpointStateOutputStream::getPos()\n\nThis closes #2646.","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/2b31ec93a6245de2e30a6314a12fdbdcfb585440"},{"sha":"e332437297197659fabaed3da5ad1e00608f246e","author":{"name":"hzyuemeng1","email":"346bfcff93506cd15958fb7ba8a4b5e9c530210e@corp.netease.com"},"message":"[FLINK-4879] Make KafkaTableSource public\n\nThis closes #2678","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/e332437297197659fabaed3da5ad1e00608f246e"},{"sha":"45762162fe7c23fd921db1e0f826b2906bfe1dcd","author":{"name":"manuzhang","email":"77841b47431c7550620f82a815e3a9dd043dbecb@gmail.com"},"message":"[FLINK-4862] fix Timer register in ContinuousEventTimeTrigger\n\nThis closes #2671","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/45762162fe7c23fd921db1e0f826b2906bfe1dcd"},{"sha":"c4783c856a8ea71271d411fa8c4dc9c484f29ff0","author":{"name":"Greg Hogan","email":"ab3bf20a456957ab3c21b104b37d8a70f0061e3c@greghogan.com"},"message":"[FLINK-4824] [client] CliFrontend shows misleading error message\n\nWhen a command-line program is run but no Flink job is executed the\nmessage to the user is now displayed without the stacktrace.\n\nWhen a Flink program throws ProgramParametrizationException the\noptional message is printed to stderr without a stacktrace.\n\nThis closes #2662","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/c4783c856a8ea71271d411fa8c4dc9c484f29ff0"},{"sha":"c4f9f0d78d65a7ce7290820ae9fb2919c9116e57","author":{"name":"Greg Hogan","email":"ab3bf20a456957ab3c21b104b37d8a70f0061e3c@greghogan.com"},"message":"[FLINK-4204] [gelly] Clean up gelly-examples\n\nMoves drivers into separate package. Adds default main class to print\nusage listing included classes. Includes documentation for running\nGelly examples.\n\nThis closes #2670","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/c4f9f0d78d65a7ce7290820ae9fb2919c9116e57"},{"sha":"77258a007ae4dde525d0274bb4d63e76d834bfe0","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-4773] [metrics] [refactor] Rename IOMetricGroup to TaskIOMetricGroup","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/77258a007ae4dde525d0274bb4d63e76d834bfe0"},{"sha":"022ceb58bd6c65b2cf3426b284bc0950b0ce865d","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-4773] [metrics] [refactor] Introduce OperatorIOMetricGroup","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/022ceb58bd6c65b2cf3426b284bc0950b0ce865d"},{"sha":"dc0b3430f8d243b1876125e4949e733ae757aa96","author":{"name":"twalthr","email":"3b937f4608445891ad01c55897b04eb069f446af@apache.org"},"message":"[FLINK-4639] [table] Introduce CalciteConfig to make Calcite features more pluggable.\n\nThis closes #2521\nThis closes #1617 // closing PR after discussion","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/dc0b3430f8d243b1876125e4949e733ae757aa96"},{"sha":"11fa089d6ae8ef8f8a884865ff50e81407389a95","author":{"name":"Jark Wu","email":"1a633f7c3371953c5e5011280efaa0eb236c73fb@alibaba-inc.com"},"message":"[FLINK-4762] [table] Use plural in time interval units\n\nThis closes #2688","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/11fa089d6ae8ef8f8a884865ff50e81407389a95"},{"sha":"307eae6e225f450ad953f1135e504e6d2e5b5d80","author":{"name":"Tzu-Li (Gordon) Tai","email":"365712edb57746e0418ca654594db9d64fc90658@apache.org"},"message":"[hotfix] [kafka] Fix RackAwareMode instantiation in Kafka 0.10 tests\n\nThis closes #2654","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/307eae6e225f450ad953f1135e504e6d2e5b5d80"},{"sha":"1db14fc06198e5519c7e71c418f5277bdc2104fc","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-3950] Implement MeterView\n\nThis closes #2443.","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/1db14fc06198e5519c7e71c418f5277bdc2104fc"},{"sha":"1d46c9d3623519e92b9cd7f147f15cbde527fb65","author":{"name":"Stephan Ewen","email":"aca661980edc82bcd0d553be7ee17e3d62509c0a@apache.org"},"message":"[hotfix] Fix unnecessary stream wrapping for Netty Error Message Frames","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/1d46c9d3623519e92b9cd7f147f15cbde527fb65"},{"sha":"fa14986161fe2fae2d8ea62f7c079f0c76b9361b","author":{"name":"Stephan Ewen","email":"aca661980edc82bcd0d553be7ee17e3d62509c0a@apache.org"},"message":"[hotfix] [kafka consumer] Improve logging For Kafka Consumer 0.8 shutdown\n\nThis does not log InterruptedExceptions on shutdown any more, because those always come\nper the Task's cancelation strategy.\n\nThis also slightly improves the behavior of joining on the spawned simple consumer threads on shutdown.","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/fa14986161fe2fae2d8ea62f7c079f0c76b9361b"},{"sha":"baf057a4815ebee67f439a55074280fb9ac48aaf","author":{"name":"Greg Hogan","email":"ab3bf20a456957ab3c21b104b37d8a70f0061e3c@greghogan.com"},"message":"[hotfix] [gelly] Driver usage and configuration\n\nFixes driver usages to print error messages.\n\nRegisters user command-line parameters for web UI configuration.","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/baf057a4815ebee67f439a55074280fb9ac48aaf"},{"sha":"44f3977e7fee44a3601b651a523c4ab37ed5a15d","author":{"name":"twalthr","email":"3b937f4608445891ad01c55897b04eb069f446af@apache.org"},"message":"[FLINK-4691] [table] Add group-windows for streaming tables to Table API.\n\nThis closes #2562.","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/44f3977e7fee44a3601b651a523c4ab37ed5a15d"},{"sha":"de03e0cea16006f04b5f62d3ff70f583f5db9e4f","author":{"name":"Fabian Hueske","email":"2f517b29f2ee44468d1de8a889fd55e4d0532902@apache.org"},"message":"[FLINK-4691] [table] Rework window property extraction.\n\n- Deduplicate aggregations and window properties in Table API","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/de03e0cea16006f04b5f62d3ff70f583f5db9e4f"},{"sha":"fe1654c680cad692e19ce262c402fd9756e8602a","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"[FLINK-4924] Simplify Operator Test Harness Constructors","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/fe1654c680cad692e19ce262c402fd9756e8602a"},{"sha":"d0c6842ae6fe31fb60b00314de3bafdcfd92957e","author":{"name":"kl0u","email":"1f09c57e6554e446feec7f25de5ccb0774f17620@gmail.com"},"message":"[FLINK-4892] Change TestHarness.snapshot() to return OperatorStateHandles\n\nThis makes it symmetric with initializeState()","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/d0c6842ae6fe31fb60b00314de3bafdcfd92957e"},{"sha":"c0192ecad161ce85c07e448537027ac619ca2d14","author":{"name":"kl0u","email":"1f09c57e6554e446feec7f25de5ccb0774f17620@gmail.com"},"message":"[FLINK-4892] Snapshot TimerService using Key-Grouped State\n\nThis also removes StreamCheckpointedOperator from AbstractStreamOperator\nwhich was added as an interim solution for snapshotting the timers.","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/c0192ecad161ce85c07e448537027ac619ca2d14"},{"sha":"b673760d3d2ebe98a97786fb0fdf194db1cb6709","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"[FLINK-4892] Re-enable RescalingITCase\n\nWith AbstractStreamOperator no longer implementing\nStreamCheckpointedOperator the test passes again.","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/b673760d3d2ebe98a97786fb0fdf194db1cb6709"}]}
{"actor":{"display_login":"aljoscha"}}