{"push_id":1427637620,"size":40,"distinct_size":40,"ref":"refs/heads/flink4895","head":"f6c83070b4133a4da45e620dce20e6bd9b55e536","before":"4e21f3ef26f8ce2d863b1082c5b7537a2b27f3dc","commits":[{"sha":"a42eafb40e1724efb7f7e680c32b86b4a66589cc","author":{"name":"Stephan Ewen","email":"aca661980edc82bcd0d553be7ee17e3d62509c0a@apache.org"},"message":"[FLINK-5123] [docs] Add description how to build a properly shaded build with different Maven versions","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/a42eafb40e1724efb7f7e680c32b86b4a66589cc"},{"sha":"1f9c0cf8522481c1a1007d98d90b30baff5c18ca","author":{"name":"Tzu-Li (Gordon) Tai","email":"365712edb57746e0418ca654594db9d64fc90658@apache.org"},"message":"[FLINK-4155] [kafka] Move partition list fetching  to open() for Kafka producers\n\nThe fetched partition list from Kafka in open() is sorted by partition id\nso that subtasks will have the same list across failures. To compensate the original\nuse of the KafkaProducer instantiation in the constructor to eagerly\nensure that required producer configs are provided, we check that at least\nthe bootstrap servers are set.\n\nThis change also includes refactoring of AtLeastOnceProducerTest for a more\ncomplete suite of tests on FlinkKafkaProducerBase.\n\nThis closes #2681.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/1f9c0cf8522481c1a1007d98d90b30baff5c18ca"},{"sha":"698e53e473fa0f78ed1e23716a50adc914563754","author":{"name":"Yassine Marzougui","email":"09b13d2729c39f48a9f062a78d2fbfe28e2d9dc1@mindlytix.com"},"message":"[FLINK-3869] Replace WindowedStream.apply() by reduce()/fold()\n\nBefore, there where these overloads for apply():\n - appply(ReduceFunction, WindowFunction)\n - apply(T initial, FoldFunction, WindowFunction)\n\nThese are now called reduce() and fold(). We keep the old methods and\ndeprecate them for compatibility.\n\nThis also fixes a problem with apply(T initial, FoldFunction,\nWindowFunction) being to restrictive.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/698e53e473fa0f78ed1e23716a50adc914563754"},{"sha":"ae4b274a9919d01a236df4e819a0a07c5d8543ac","author":{"name":"Till Rohrmann","email":"9006f1940e337c648feb3df40b3beb29c822bbfc@apache.org"},"message":"[FLINK-5082] Pull ExecutorService lifecycle management out of the JobManager\n\nThe provided ExecutorService will no longer be closed by the JobManager. Instead the\nlifecycle is managed outside of it where it was created. This will give a nicer behaviour,\nbecause it better seperates responsibilities.\n\nThis closes #2820.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/ae4b274a9919d01a236df4e819a0a07c5d8543ac"},{"sha":"3fb92d8687f03c1fac8b87396b2b5a7ff29f6dd6","author":{"name":"Till Rohrmann","email":"9006f1940e337c648feb3df40b3beb29c822bbfc@apache.org"},"message":"[FLINK-5073] Use Executor to run ZooKeeper callbacks in ZooKeeperStateHandleStore\n\nUse dedicated Executor to run ZooKeeper callbacks in ZooKeeperStateHandleStore instead\nof running it in the ZooKeeper client's thread. The callback can be blocking because it\ndiscards state which might entail deleting files from disk.\n\nIntroduce dedicated Executor for blocking io operations\n\nThis closes #2815.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/3fb92d8687f03c1fac8b87396b2b5a7ff29f6dd6"},{"sha":"c590912c93a4059b40452dfa6cffbdd4d58cac13","author":{"name":"Till Rohrmann","email":"9006f1940e337c648feb3df40b3beb29c822bbfc@apache.org"},"message":"[FLINK-5085] Execute CheckpointCoordinator's state discard calls asynchronously\n\nThe CheckpointCoordinator is now given an Executor which is used to execute the state discard\ncalls asynchronously. This will prevent blocking operations to be executed from within the\ncalling thread.\n\nShut down ExecutorServices gracefully\n\nThis closes #2825.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/c590912c93a4059b40452dfa6cffbdd4d58cac13"},{"sha":"ba8ed263695d16eacb4bdfdf195dd22c83bb53ed","author":{"name":"Stefan Richter","email":"f4fa93155523de454f7719daac3d15e33e599d43@data-artisans.com"},"message":"[FLINK-4910] Introduce safety net for closing file system streams\n\nThis closes #2691.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/ba8ed263695d16eacb4bdfdf195dd22c83bb53ed"},{"sha":"f5af7f1025aac9cac3f83de5f0e3aece5730ec0f","author":{"name":"Stefan Richter","email":"f4fa93155523de454f7719daac3d15e33e599d43@data-artisans.com"},"message":"[FLINK-5107] Introduced limit for prior execution attempt history\n\nThis closes #2837.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/f5af7f1025aac9cac3f83de5f0e3aece5730ec0f"},{"sha":"4c23879a5743b862b93d3c4267244235266163e7","author":{"name":"Till Rohrmann","email":"9006f1940e337c648feb3df40b3beb29c822bbfc@apache.org"},"message":"[FLINK-5107] Handle evicted execution attempts in request handlers\n\nIf a prior execution attempt cannot be retrieved because it has been evicted before,\nthe request handler will now throw a meaningful exception to notify the requester\nabout the evicted execution attempt.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/4c23879a5743b862b93d3c4267244235266163e7"},{"sha":"4653ad388b05b3ba7e37982bb8af09e7fcbed6be","author":{"name":"twalthr","email":"3b937f4608445891ad01c55897b04eb069f446af@apache.org"},"message":"[FLINK-5124] [table] Support more temporal arithmetic\n\nThis closes #2851.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/4653ad388b05b3ba7e37982bb8af09e7fcbed6be"},{"sha":"0d3ff88b369fbb1b0a8fb0e8263c9ce0a9da1583","author":{"name":"Aleksandr Chermenin","email":"0d0aa9257c2af436edefd9ee20ce25cb315ef3e7@epam.com"},"message":"[FLINK-2608] Updated Twitter Chill version.\n\n[FLINK-2608] Updated test with Java collections.\n\n[FLINK-2608] Updated Chill and Kryo dependencies.\n\n[FLINK-2608] Added collections serialization test.\n\nThis closes #2623.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/0d3ff88b369fbb1b0a8fb0e8263c9ce0a9da1583"},{"sha":"3e3a90d89cd62b07d3790ccea7bb1a30db9cc9d2","author":{"name":"Till Rohrmann","email":"9006f1940e337c648feb3df40b3beb29c822bbfc@apache.org"},"message":"[FLINK-5010] [akka] Introduce default configuration values for Akka's deathwatch\n\nSet the akka deathwatch interval to 10s, the akka deathwatch pause to 60s and the tcp\nconnection timeout to 20s per default.\n\nThis closes #2831.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/3e3a90d89cd62b07d3790ccea7bb1a30db9cc9d2"},{"sha":"4656350fc33d42ff96ad6d5e836e62172b4b0de6","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"[FLINK-5000] Rename Methods in ManagedInitializationContext\n\nThis removes \"managed\" from the OperatorStateStore and KeyedStateStore\naccess methods. There is no \"un-managed\" state and users might be\nwondering what \"managed\" means here.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/4656350fc33d42ff96ad6d5e836e62172b4b0de6"},{"sha":"e8318d6f449b0b4720ca2377eae4f98c59f5e494","author":{"name":"Makman2","email":"819dac272d6565841181a0f2e897e76751e18cf2@alice.de"},"message":"[FLINK-4900] flink-master: Allow to deploy TM with container\n\nAllows via a setting to deploy a base image on that a task manager\nruns.\n\nThis closes #2703.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/e8318d6f449b0b4720ca2377eae4f98c59f5e494"},{"sha":"7d91b9ec71c9b711e04a91f847f5c85d3f561da6","author":{"name":"Fabian Hueske","email":"2f517b29f2ee44468d1de8a889fd55e4d0532902@apache.org"},"message":"[FLINK-2662] [optimizer] Fix computation of global properties of union operator.\n\n- Fixes invalid shipping strategy between consecutive unions.\n\nThis closes #2848.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/7d91b9ec71c9b711e04a91f847f5c85d3f561da6"},{"sha":"06d252e89b58c5947b331cf24a552d11ff8767e8","author":{"name":"twalthr","email":"3b937f4608445891ad01c55897b04eb069f446af@apache.org"},"message":"[FLINK-5143] [table] Add EXISTS to list of supported SQL operators.\n\nThis closes #2853.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/06d252e89b58c5947b331cf24a552d11ff8767e8"},{"sha":"74e0971a5511c511feb94bee7a0ce39eb9951b62","author":{"name":"Jincheng Sun","email":"9fa685494ab6ed20cf2b884cf7ef2572367ab689@gmail.com"},"message":"[FLINK-4937] [table] Add incremental group window aggregation for streaming Table API.\n\nThis closes #2792.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/74e0971a5511c511feb94bee7a0ce39eb9951b62"},{"sha":"3458a6615cf1db66f32650bbaae2841b570fa647","author":{"name":"Robert Metzger","email":"0267b3fb5eee07973aded5cd271875b0cce4ade0@apache.org"},"message":"[hotfix][docs] Stream joins don't support tuple position keys","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/3458a6615cf1db66f32650bbaae2841b570fa647"},{"sha":"16ee4a5ce717987d824593b1f9fdaafa44d98632","author":{"name":"Robert Metzger","email":"0267b3fb5eee07973aded5cd271875b0cce4ade0@apache.org"},"message":"[hotfix] [streaming] Fix type extraction for joined streams.\n\nThis closes #2755.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/16ee4a5ce717987d824593b1f9fdaafa44d98632"},{"sha":"2029c14eb7d5b6788eb9297c271dd16a0d819fbe","author":{"name":"Maximilian Michels","email":"0babbab6c2ab1e494e95176e73e7efe04dd4b11a@apache.org"},"message":"[FLINK-5149] let ContinuousEventTimeTrigger fire at the end of the window\n\nThis changes the ContinuousEventTimeTrigger to behave like the\nEventTimeTrigger in the sense that it also triggers at the end of the\nwindow.\n\nThis prevents the trigger from not firing at all in case the first\ntrigger interval is after the window end.\n\nThis closes #2860.\n\n[typo] fix toString() of ContinuousEventTimeTrigger\n\nThis closes #2854.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/2029c14eb7d5b6788eb9297c271dd16a0d819fbe"}]}
{"actor":{"display_login":"rmetzger"}}