{"push_id":1060565774,"size":21,"distinct_size":21,"ref":"refs/heads/master","head":"ed1e52a106e9ce3789fab975e34715de2d923bec","before":"b1e5086455257e5b7d967fd0715f5a2ab30734aa","commits":[{"sha":"505512dbe461b9840dde6197c71dbb90b49c0495","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-3614] Remove Non-Keyed Window Operator\n\nInstead we use a dummy KeySelector and the regular WindowOperator now.","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/505512dbe461b9840dde6197c71dbb90b49c0495"},{"sha":"6cd8ceb10c841827cf89b74ecf5a0495a6933d53","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-3174] Add MergingWindowAssigner and SessionWindows\n\nThis introduces MergingWindowAssigner, an extension of WindowAssigner\nthat can merge windows. When using a MergingWindowAssigner the\nWindowOperator eagerly merges windows when processing elements.\n\nFor keeping track of in-flight windows and for merging windows this adds\nMergingWindowSet, this keeps track of windows per key.\n\nOnly when using a MergingWindowAssigners is the more costly merging\nlogic used in the WindowOperator.\n\nFor triggers there is a new method Trigger.onMerge() that notifies the\ntrigger of the new merged window. This allows the trigger to set a timer\nfor the newly merged window. Only triggers that return true\nfrom Trigger.canMerge() can be used with MergingWindowAssigner. Trigger\nhas default implementations for canMerge() and onMerge(), we return\nfalse and onMerge() throws an Exception.\n\nThis also adds AbstractStateBackend.mergePartitionedStates for merging\nstate of several source namespaces into a target namespace. This is only\npossible for the newly introduced MergingState which is an extension of\nAppendingState. Only ReducingState and ListState are MergingState while\nFoldingState is now an AppendingState.\n\nThis enables proper support for session windows.\n\nThis also adds the EventTimeSessionWindows and ProcessingTimeSessionWindows\nwindow assigners and adapts an existing session example and adds test cases.","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/6cd8ceb10c841827cf89b74ecf5a0495a6933d53"},{"sha":"02a3dfdeaa4d7af7257c2526c6570a28be876c86","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-3283] Improve Kafka test stability","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/02a3dfdeaa4d7af7257c2526c6570a28be876c86"},{"sha":"051fa2bc8151e2f7a251d2c9b7496f9cef98b47c","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[docs] Add separate AWS setup page","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/051fa2bc8151e2f7a251d2c9b7496f9cef98b47c"},{"sha":"13c53f2ef3ab2f7a5357c83d23fea4c86b7eb92c","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[docs] Remove obsolete Flink on Tez figures","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/13c53f2ef3ab2f7a5357c83d23fea4c86b7eb92c"},{"sha":"b04d51a129a3341887e7a0866557c9871f58e94c","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[docs] Fix broken links in Concepts","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/b04d51a129a3341887e7a0866557c9871f58e94c"},{"sha":"5a60ae4a9ccbe1b677e0b5125e494040da8a5dda","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[docs] Add missing license to new page","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/5a60ae4a9ccbe1b677e0b5125e494040da8a5dda"},{"sha":"142912b031df42d2abe43b41e98be5596cb3a7f9","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[FLINK-3689] do not shutdown test ActorSystem\n\nInstead of shutting down the ActorSystem created in the test, we simply send a\nmessage upon executing the shutdown method of the JobManager, TaskManager, and\nResourceManager. This ensures we can check for shutdown code execution without\ninterfering with the test.\n\nThis closes #1852.","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/142912b031df42d2abe43b41e98be5596cb3a7f9"},{"sha":"24f89b7f1695ee095a2a161990bdcfd8c09283a5","author":{"email":"d22fe4c37466fd2128f6ceeb947bbfb4c52e5900@gmail.com","name":"Martin Liesenberg"},"message":"FLINK-3529 Add template for pull requests\n\n- link from CONTRIBUTING.md to PR template\n- add it to excluded file of rat plugin\n\nThis closes #1729.","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/24f89b7f1695ee095a2a161990bdcfd8c09283a5"},{"sha":"b3186b6a109e4cd43216799e2f1c63ad8646bdab","author":{"email":"74d2b1434a38d8bcb1444d7dcc25bd20b27624c3@gmail.com","name":"Lasse Dalegaard"},"message":"[FLINK-3637] Refactored output stream handling from RollingSink.\n\nThe Writer interface now deals directly with filesystem and path, rather\nthan the raw output stream.\n\nSince the RollingSink no longer has access to the raw output stream, it\ncannot directly determine the current size of the file. A getPos()\nmethod has been added to the Writer interface, so the RollingSink can.\nretrieve the current file size.\n\nFinally, flush() has been extended to return the offset that the file\nmust be truncated to at recovery.","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/b3186b6a109e4cd43216799e2f1c63ad8646bdab"},{"sha":"db8c5cc5c9af7f0cca931cd6020aff568d8d88f7","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[docs] Add back pressure monitoring page","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/db8c5cc5c9af7f0cca931cd6020aff568d8d88f7"},{"sha":"d7948fad6a73fdefae43cd42193342398a1581aa","author":{"email":"a26e691c1e2579e0b3e84545031f591986d1e6fb@gmail.com","name":"nikste"},"message":"[FLINK-2522] Streaming support for Flink-Scala-Shell","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/d7948fad6a73fdefae43cd42193342398a1581aa"},{"sha":"593463bde36e35f55ccde2cec9f35fe6f49814e4","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[FLINK-2522] improve welcome message of Scala shell for streaming\n\nThis closes #1412.","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/593463bde36e35f55ccde2cec9f35fe6f49814e4"},{"sha":"02ef68fb4adbd413fa159c35980412f280179cbf","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@apache.org","name":"mjsax"},"message":"[FLINK-3523] [Storm-Compatibility] Added SplitStreamMapper to program to get rid of SplitStreamType wrapper\n - additionally reworked split ITCases\n   * unified to single test\n   * make Windows compatible (using tmp files)\n   * added test case for embedded splitting\n\nThis closes #1844","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/02ef68fb4adbd413fa159c35980412f280179cbf"},{"sha":"a3415028dd7bec24e170c0d8a3531b19c021aaaf","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[hotfix] Fix EvictingWindowOperator to work with MergingWindowAssigner","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/a3415028dd7bec24e170c0d8a3531b19c021aaaf"},{"sha":"e5b93da0eda610e163a5d4a72cb23bd69d9c136a","author":{"email":"66fa43226e7d5aa0e75fe1db26f6d437ee80e1e6@expedia.com","name":"Shannon Carey"},"message":"[FLINK-3711][docs] Documentation of Scala fold()() uses correct syntax\n\nCloses #1860","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/e5b93da0eda610e163a5d4a72cb23bd69d9c136a"},{"sha":"3fe53d39fe452aecaa7b075b94b0ca33a1d71864","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-3654] Disable Write-Ahead-Log in RocksDB State","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/3fe53d39fe452aecaa7b075b94b0ca33a1d71864"},{"sha":"9f52422350e145454d4b6972741944b1fd2185f2","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-3697] Properly access type information for nested POJO key selection\n\nThis closes #1851","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/9f52422350e145454d4b6972741944b1fd2185f2"},{"sha":"a234719a25836f8c125aee27f1235caf42943b3b","author":{"email":"8c0e376f61657147e53817030cca1a650b2c8103@tngtech.com","name":"Konstantin Knauf"},"message":"[FLINK-3688] WindowOperator.trigger() does not emit Watermark anymore\n\nConflicts:\n\tflink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/a234719a25836f8c125aee27f1235caf42943b3b"},{"sha":"b368cb2d5c3bc67f1fa82f9c2b77b46ce1684962","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-3712] Make all dynamic properties available to the CLI frontend\n\nThis closes #1863","distinct":true,"url":"https://api.github.com/repos/StephanEwen/incubator-flink/commits/b368cb2d5c3bc67f1fa82f9c2b77b46ce1684962"}]}