{"push_id":1422371973,"size":313,"distinct_size":264,"ref":"refs/heads/FLINK-4565","head":"7699c37a840dcb62c4984e0d63f87813d355d1f8","before":"775b70f2fed476112d90cbbb68fa7652cf21c98d","commits":[{"sha":"62d4af8816b696c4ec645b7dad2b8887d5f8519c","author":{"name":"twalthr","email":"3b937f4608445891ad01c55897b04eb069f446af@apache.org"},"message":"[FLINK-3656] [table] Reduce number of ITCases\n\nThis closes #2563.","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/62d4af8816b696c4ec645b7dad2b8887d5f8519c"},{"sha":"84af0b90ec81bbe2af73a56cc0483166314a492a","author":{"name":"Stephan Ewen","email":"aca661980edc82bcd0d553be7ee17e3d62509c0a@apache.org"},"message":"[FLINK-4710] [build] Remove Guice Dependency from Hadoop2\n\nThis dependency is transitively pulled, but not necessary for the parts of the\nHadoop libraries used by Flink.","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/84af0b90ec81bbe2af73a56cc0483166314a492a"},{"sha":"8243138c3ffb0849a7150d3c2df56eaffccd8d75","author":{"name":"Stephan Ewen","email":"aca661980edc82bcd0d553be7ee17e3d62509c0a@apache.org"},"message":"[FLINK-4708] [build] Properly scope Kerberos Test Cluster dependency for tests","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/8243138c3ffb0849a7150d3c2df56eaffccd8d75"},{"sha":"7758571ae7a6a26859d91eb80e7b4df689e79c46","author":{"name":"twalthr","email":"3b937f4608445891ad01c55897b04eb069f446af@apache.org"},"message":"[FLINK-3656] [table] Consolidate ITCases\n\nMerge FilterIT/SelectIT to CalcITCases\nMerge FromDataSet/ToTable to TableEnvironmentITCases\nMerge aggregating ITCases\nAll batch ITCases use TableProgramsTestBase\n\nThis closes #2566.","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/7758571ae7a6a26859d91eb80e7b4df689e79c46"},{"sha":"477d1c5d4ca6f469b3c87bc1f7962ece805cae1d","author":{"name":"Till Rohrmann","email":"9006f1940e337c648feb3df40b3beb29c822bbfc@apache.org"},"message":"[FLINK-4711] Let the Task trigger partition state requests and handle their responses\n\nThis PR makes changes the partition state check in a way that the Task is now responsible\nfor triggering the state check instead of the SingleInputGate. Furthermore, the operation\nreturns a future containing the JobManager's answer. That way we don't have to route the\nresponse through the TaskManager and can add automatic retries in case of a timeout.\n\nThe PR removes the JobManagerCommunicationFactory and gets rid of the excessive\nPartitionStateChecker and ResultPartitionConsumableNotifier creation. Instead of creating\nfor each SingleInputGate one PartitionStateChecker we create one for the TaskManager which\nis reused across all SingleInputGates. The same applies to the\nResultPartitionConsumableNotifier.\n\nThis closes #2569.","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/477d1c5d4ca6f469b3c87bc1f7962ece805cae1d"},{"sha":"2afc092461cf68cf0f3c26a3ab4c58a7bd68cf71","author":{"name":"Liwei Lin","email":"878182135bcb2086b9b1c72277449d6e06bbf76f@gmail.com"},"message":"[FLINK-4573] [web dashboard] Fix potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler\n\nThis closes #2556","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/2afc092461cf68cf0f3c26a3ab4c58a7bd68cf71"},{"sha":"53ed6adac8cbe6b5dcb692dc9b94970f3ec5887c","author":{"name":"Stefan Richter","email":"f4fa93155523de454f7719daac3d15e33e599d43@data-artisans.com"},"message":"[FLINK-4379] [checkpoints] Introduce rescalable operator state\n\nThis introduces the Operator State Backend, which stores state that is not partitioned\nby a key. It replaces the 'Checkpointed' interface.\n\nAdditionally, this introduces CheckpointStateHandles as container for all checkpoint related state handles\n\nThis closes #2512","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/53ed6adac8cbe6b5dcb692dc9b94970f3ec5887c"},{"sha":"6f8f5eb3b9ba07cd3bb4d9f7edd43d4b8862acbe","author":{"name":"Stephan Ewen","email":"aca661980edc82bcd0d553be7ee17e3d62509c0a@apache.org"},"message":"[FLINK-4379] [checkpoints] Fix minor bug and improve debug logging","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/6f8f5eb3b9ba07cd3bb4d9f7edd43d4b8862acbe"},{"sha":"92f4539afc714f7dbd293c3ad677b3b5807c6911","author":{"name":"Stephan Ewen","email":"aca661980edc82bcd0d553be7ee17e3d62509c0a@apache.org"},"message":"[FLINK-4702] [kafka connector] Commit offsets to Kafka asynchronously and don't block on polls\n\nLetting the Kafka commit block on polls means that 'notifyCheckpointComplete()' may take\nvery long. This is mostly relevant for low-throughput Kafka topics.","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/92f4539afc714f7dbd293c3ad677b3b5807c6911"},{"sha":"ae219a8c48210cc261ec0a6c7f5aaf261e3d2fd7","author":{"name":"Max Kuklinski","email":"4c4612655e98f81f15943f4d1fcc91de0044196a@live.de"},"message":"[FLINK-4618] [kafka-connector] Incremented the commited offset by one to avoid duplicate read message.","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/ae219a8c48210cc261ec0a6c7f5aaf261e3d2fd7"},{"sha":"9dbd1e3f79cc2195b4becf00d11a8cca8c3a18b1","author":{"name":"Tzu-Li (Gordon) Tai","email":"365712edb57746e0418ca654594db9d64fc90658@apache.org"},"message":"[FLINK-4618] [kafka-connector] Minor improvements to comment and variable naming\n\nThis closes #2579","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/9dbd1e3f79cc2195b4becf00d11a8cca8c3a18b1"},{"sha":"a79efdc23e1bd35eb7cd2e5eb9551cc297c02dd5","author":{"name":"Martin Junghanns","email":"cd2a952012856ea3de90f5a61470421b01126382@gmx.net"},"message":"[FLINK-4624] [gelly] Support null values in Graph Summarization\n\n* Bug was caused by serializers that cannot handle null values (e.g. Long)\n* VertexGroupItem now uses Either<NullValue, VV> instead of VV\n* Generalized test cases\n* Added tests for vertex/edge values of type Long\n* Replaced Guava Lists.newArrayList() with new ArrayList<>()\n\nThis closes #2527","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/a79efdc23e1bd35eb7cd2e5eb9551cc297c02dd5"},{"sha":"95c08eab36bfa09c501a84f5b5f116d666d03ae1","author":{"name":"Greg Hogan","email":"ab3bf20a456957ab3c21b104b37d8a70f0061e3c@greghogan.com"},"message":"[FLINK-4643] [gelly] Average Clustering Coefficient\n\nDirected and undirected analytics computing the average clustering\ncoefficient over vertices in a graph and an updated driver.\n\nThis closes #2528","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/95c08eab36bfa09c501a84f5b5f116d666d03ae1"},{"sha":"171d10930b3904f51b7d60531bfc0837b7cc19bd","author":{"name":"twalthr","email":"3b937f4608445891ad01c55897b04eb069f446af@apache.org"},"message":"[FLINK-3656] [table] Convert expression tests to unit tests\n\nThis closes #2567.","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/171d10930b3904f51b7d60531bfc0837b7cc19bd"},{"sha":"a71133945e66ec471b4cb07da0693d545c40923c","author":{"name":"Jark Wu","email":"1a633f7c3371953c5e5011280efaa0eb236c73fb@alibaba-inc.com"},"message":"[FLINK-4068] [table] Move constant computations out of code-generated\n\nThis closes #2560.","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/a71133945e66ec471b4cb07da0693d545c40923c"},{"sha":"f00e1e7c5578caf52eaffc5cbdd102589c13f52d","author":{"name":"twalthr","email":"3b937f4608445891ad01c55897b04eb069f446af@apache.org"},"message":"[FLINK-4068] [table] Reduce expression also for filter/project","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/f00e1e7c5578caf52eaffc5cbdd102589c13f52d"},{"sha":"72e6b760fd951764c3ecc6fc191dc99a42d55e0b","author":{"name":"Jark Wu","email":"1a633f7c3371953c5e5011280efaa0eb236c73fb@alibaba-inc.com"},"message":"[FLINK-4546] [table] Remove STREAM keyword in Stream SQL\n\nThis closes #2454.","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/72e6b760fd951764c3ecc6fc191dc99a42d55e0b"},{"sha":"eece0dd05bc38b88fcb6cbcef15add7f98eab456","author":{"name":"Fabian Hueske","email":"2f517b29f2ee44468d1de8a889fd55e4d0532902@apache.org"},"message":"[hotfix] [kafka] Fix NPE in Kafka09Fetcher","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/eece0dd05bc38b88fcb6cbcef15add7f98eab456"},{"sha":"5a573c6bc29c313d34981336d5bfc05185d323d2","author":{"name":"Maximilian Michels","email":"0babbab6c2ab1e494e95176e73e7efe04dd4b11a@apache.org"},"message":"[FLINK-4732] remove maven junction plugin\n\nOn Windows, the plugin downloads and executes code from the author's\nweb site. The downloaded file is not signed in the same way as Maven\nartifacts from Maven central which have to be signed with the\ndeveloper's key. This could be a potential target for attackers.\n\nThis closes #2586","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/5a573c6bc29c313d34981336d5bfc05185d323d2"},{"sha":"efb40cfc5f0c738cfd281b182b696495b5985a96","author":{"name":"Tzu-Li (Gordon) Tai","email":"365712edb57746e0418ca654594db9d64fc90658@apache.org"},"message":"[hotfix] [kafka] Committed offset value set in KafkaTopicPartitionState should also be incremented by 1.\n\nThe broken behaviour was introduced in the last hotfix commit eece0dd0.","distinct":false,"url":"https://api.github.com/repos/NickolayVasilishin/flink/commits/efb40cfc5f0c738cfd281b182b696495b5985a96"}]}
{"actor":{"display_login":"NickolayVasilishin"}}