{"push_id":1598725163,"size":19,"distinct_size":12,"ref":"refs/heads/mergeStage","head":"ad5c3ab1adf6f961356e0b1dc0935d5f261dbcbc","before":"41d1382f63e0666f2b47f98a6c056330b0e9ba10","commits":[{"sha":"a2e6fb06c404a31294c53903fbaeaac666403dc8","author":{"name":"kl0u","email":"1f09c57e6554e446feec7f25de5ccb0774f17620@gmail.com"},"message":"[FLINK-5937] [doc] Add documentation about the stream task lifecycle","distinct":false,"url":"https://api.github.com/repos/fhueske/flink/commits/a2e6fb06c404a31294c53903fbaeaac666403dc8"},{"sha":"f37507d9434d5ae16f7d164686af2aa5438995bf","author":{"name":"xiaogang.sxg","email":"9fe062dcccdcc466e6a3b45c16711d1a250c1664@alibaba-inc.com"},"message":"[FLINK-5917] [statebackends] Remove size() method from MapState\n\nThis closes #3462","distinct":false,"url":"https://api.github.com/repos/fhueske/flink/commits/f37507d9434d5ae16f7d164686af2aa5438995bf"},{"sha":"050f9a416173f74022a1fd10eae2bf502ae1c2ae","author":{"name":"Dawid Wysakowicz","email":"62a712c4a478341376ba387fc10a4dd6cda80bf1@getindata.com"},"message":"[FLINK-5864] [cep] Fix duplicate output patterns problem\n\nThe problem was that the Dewey numbers in the\nNFA::computeNextStates() were not updated correctly\nwhen branching, i.e. from the same state  we had\ntwo new valid states.","distinct":false,"url":"https://api.github.com/repos/fhueske/flink/commits/050f9a416173f74022a1fd10eae2bf502ae1c2ae"},{"sha":"2d1721bb9b17333c3c06e3675a24d344aed3c87f","author":{"name":"Fabian Hueske","email":"2f517b29f2ee44468d1de8a889fd55e4d0532902@apache.org"},"message":"[hotfix] [table] Fix initialization of accumulators for MIN and MAX aggregates.","distinct":false,"url":"https://api.github.com/repos/fhueske/flink/commits/2d1721bb9b17333c3c06e3675a24d344aed3c87f"},{"sha":"14fab4c412048f769209855d876221817e73ba25","author":{"name":"shaoxuan-wang","email":"f764b0bfac6d349b9971df54aa0c25df2c7a8b78@gmail.com"},"message":"[FLINK-5955] [table] Fix aggregations with ObjectReuse enabled by pairwise merging of accumulators.\n\nThis closes #3465.","distinct":false,"url":"https://api.github.com/repos/fhueske/flink/commits/14fab4c412048f769209855d876221817e73ba25"},{"sha":"c31f95cab884452dba47306c2b7fb536f047b8ae","author":{"name":"shaoxuan-wang","email":"f764b0bfac6d349b9971df54aa0c25df2c7a8b78@gmail.com"},"message":"[FLINK-5927] [table] Remove old Aggregate interface, built-in functions, and tests.\n\nThis closes #3465.","distinct":false,"url":"https://api.github.com/repos/fhueske/flink/commits/c31f95cab884452dba47306c2b7fb536f047b8ae"},{"sha":"728c936dd2ac18701e1d8696da251aec351b2ae6","author":{"name":"金竹","email":"492f75e5101123db213e41b5d93facb26ce369c6@alibaba-inc.com"},"message":"[FLINK-5219] [table] Add non-grouped session windows for batch tables.\n\nThis closes #3266.","distinct":false,"url":"https://api.github.com/repos/fhueske/flink/commits/728c936dd2ac18701e1d8696da251aec351b2ae6"},{"sha":"d5c320c3b6ee7b99bb2fd72500a0caa7fea24083","author":{"name":"Kurt Young","email":"d20df6a2fe61032990198f1d4f90bea27f6917e3@gmail.com"},"message":"[FLINK-5586] [table] Extend TableProgramsClusterTestBase for object reuse mode\n\nThis closes #3339.","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/d5c320c3b6ee7b99bb2fd72500a0caa7fea24083"},{"sha":"dc00fb0c384097f0ce5b5c0be2763768c48b3f67","author":{"name":"Andrey Melentyev","email":"81ca339c15e1160d0a558cd64d1790c129dd7946@klarna.com"},"message":"[FLINK-5067] Java 8 build fixes\n\n- New type inference rules changed which overloaded methods are picked.\n- Renamed java.version property in maven to java.minor.version. This is due to the fact that overriding java.version is used by some third-party classes and they expect the version to be fully qualified.\n- Introduced Java 8 build for Travis CI\n\nThis closes #2804\nThis closes #2767","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/dc00fb0c384097f0ce5b5c0be2763768c48b3f67"},{"sha":"62517ca4b87095cb1351016e05810e4cc027c917","author":{"name":"Chico Sokol","email":"77a9637e31fbc92002cbc54087f59710ed1bfee7@applift.com"},"message":"[FLINK-5965] [docs] Fix minor typo on DropWizard wrappers\n\nThis closes #3475.","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/62517ca4b87095cb1351016e05810e4cc027c917"},{"sha":"82eddcad9674b09e90db921bc874b43b64796420","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"[FLINK-4460] Make ProcessFunction abstract, add default onTime() method\n\nThis is in preparation of allowing ProcessFunction on DataStream because\nwe will use it to allow side outputs from the ProcessFunction Context.","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/82eddcad9674b09e90db921bc874b43b64796420"},{"sha":"0228676d689b04accf1ba7d7c7f8064e121c6d88","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"[FLINK-4660] Allow ProcessFunction on DataStream\n\nIntroduce new ProcessOperator for this. Rename the pre-existing\nProcessOperator to KeyedProcessOperator.","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/0228676d689b04accf1ba7d7c7f8064e121c6d88"},{"sha":"e12f3203eda7f071daeea7c59ca32b3db7763b68","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"[FLINK-4460] Make CoProcessFunction abstract, add default onTime() method\n\nThis is in preparation of allowing CoProcessFunction on a non-keyed\nconnected stream.  we will use it to allow side outputs from the\nProcessFunction Context.","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/e12f3203eda7f071daeea7c59ca32b3db7763b68"},{"sha":"06740fb28d3f3269d040d68cbfefc5201203b60d","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"[FLINK-4660] Allow CoProcessFunction on non-keyed ConnectedStreams\n\nIntroduce new CoProcessOperator for this. Rename the pre-existing\nCoProcessOperator to KeyedCoProcessOperator.","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/06740fb28d3f3269d040d68cbfefc5201203b60d"},{"sha":"746c1efa504267e18ddc6305712d4c3717ba4cb4","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"[FLINK-4460] Update doc: ProcessFunction now possible on DataStream","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/746c1efa504267e18ddc6305712d4c3717ba4cb4"},{"sha":"821da81fe6bee4c5a33be19c08064491fd6280de","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[FLINK-5645] Store accumulators/metrics for canceled/failed tasks\n\nThis closes #3377.","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/821da81fe6bee4c5a33be19c08064491fd6280de"},{"sha":"cd801aa5c5af0a5f1facd78c8464df9aef95f094","author":{"name":"shaoxuan-wang","email":"f764b0bfac6d349b9971df54aa0c25df2c7a8b78@gmail.com"},"message":"[FLINK-5956] [table] Add retract method for AggregateFunction.\n\nThis closes #3470.","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/cd801aa5c5af0a5f1facd78c8464df9aef95f094"},{"sha":"8d713739fa5119ffd872ab5774712ba8a891150e","author":{"name":"金竹","email":"492f75e5101123db213e41b5d93facb26ce369c6@alibaba-inc.com"},"message":"[FLINK-5803] [table] Add support for procTime partitioned OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL\n\nThis closes #3397.","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/8d713739fa5119ffd872ab5774712ba8a891150e"},{"sha":"ad5c3ab1adf6f961356e0b1dc0935d5f261dbcbc","author":{"name":"Fabian Hueske","email":"2f517b29f2ee44468d1de8a889fd55e4d0532902@apache.org"},"message":"Final changes","distinct":true,"url":"https://api.github.com/repos/fhueske/flink/commits/ad5c3ab1adf6f961356e0b1dc0935d5f261dbcbc"}]}
{"actor":{"display_login":"fhueske"}}