{"push_id":750351992,"size":61,"distinct_size":1,"ref":"refs/heads/convergence","head":"0bde82898831dc4178f13ac8892851107b31b75a","before":"3e672566f058a7177669a548b4eafa56b4037d51","commits":[{"sha":"466f9bf9c98b05bf35ca29af1b04343b7c9ea5f6","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[cascading] add getJobConf() to HadoopInputSplit","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/466f9bf9c98b05bf35ca29af1b04343b7c9ea5f6"},{"sha":"ca6dd42759f180779f9dfef63535f297fcb2eaf0","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[cascading] load user classloader when configuring InputFormat\n\nThis closes #950.","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/ca6dd42759f180779f9dfef63535f297fcb2eaf0"},{"sha":"1b3bdce5ccb24a485ebc6452d16f78c770486481","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[client] send cancel message via the job manager's ActorGateway","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/1b3bdce5ccb24a485ebc6452d16f78c770486481"},{"sha":"0558644ae1a1c8e0f21867ce1963aaa625170690","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[FLINK-2324] [streaming] Partitioned state checkpointing rework + test update","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/0558644ae1a1c8e0f21867ce1963aaa625170690"},{"sha":"58cd4ea615bbbbec682ec82f6380bc30c12c5899","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[FLINK-2324] [streaming] ITCase added for partitioned states","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/58cd4ea615bbbbec682ec82f6380bc30c12c5899"},{"sha":"83e14cb15a41c417fd7d024c383a4f4d50ec5a19","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[FLINK-2324] [streaming] Added test for different StateHandle wrappers\n\nCloses #937","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/83e14cb15a41c417fd7d024c383a4f4d50ec5a19"},{"sha":"1919ae735ca557dad5f05bf787599b76fe80928f","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[cleanup] move updateAccumulators method to a more sensible location","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/1919ae735ca557dad5f05bf787599b76fe80928f"},{"sha":"68b1559319a870c3120263c5d10967ff6b690682","author":{"email":"f6773562c9b47f90844286155b23bf8af2851ee5@web.de","name":"zentol"},"message":"[FLINK-1927][FLINK-2173][py] Operator distribution rework, fix file paths\n\nPython operators are no longer serialized and shipped across the\ncluster. Instead the plan file is executed on each node, followed by\nusage of the respective operator object.\n\n- removed dill library\n- filepaths are always explicitly passed to python\n- fix error reporting\n\nThis closes #931.","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/68b1559319a870c3120263c5d10967ff6b690682"},{"sha":"3c236b2c89ed84cded0d056ac40fc728089c6f67","author":{"email":"9bcb11ac70c2fc7872d9b58e21318011c5e228e2@gmail.com","name":"Sachin Goel"},"message":"[FLINK-2238][api] Generalized fromCollection(Seq) to fromCollection(Iterable)\n\nThis closes #956","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/3c236b2c89ed84cded0d056ac40fc728089c6f67"},{"sha":"a56aad74eb35a19623d58b6dd0228ec5bc1bb422","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-2412] [runtime] Check if parent released before querying in-memory buffer in SpillableSubpartitionView","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/a56aad74eb35a19623d58b6dd0228ec5bc1bb422"},{"sha":"ce622aa99f6ec6b4325f11dbd6211a40d97c48ed","author":{"email":"9bcb11ac70c2fc7872d9b58e21318011c5e228e2@gmail.com","name":"Sachin Goel"},"message":"[FLINK-2248] add flag to disable sysout logging from cli\n\nThis closes #957.","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/ce622aa99f6ec6b4325f11dbd6211a40d97c48ed"},{"sha":"b0f237990cc52729ff1eb1de29b65e118bf59aa3","author":{"email":"16007799f5fc2216ed8210e705739ba4591e32b7@qq.com","name":"ffbin"},"message":"[FLINK-2446] [streaming] Fix SocketTextStreamFunction memory leak on reconnect\n\nCloses #965","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/b0f237990cc52729ff1eb1de29b65e118bf59aa3"},{"sha":"c58ba3da90884846a52b174098c782eb08308c25","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[hotfix] Fix SourceStreamTaskTest to switch source to running before checkpointing","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/c58ba3da90884846a52b174098c782eb08308c25"},{"sha":"645d7cd9e437d3de301ca0ce5c9cdc87bcce494b","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-2461] [tests] Guard tests that rely on unresolvable host names with the appropriate assumption.","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/645d7cd9e437d3de301ca0ce5c9cdc87bcce494b"},{"sha":"9311b9a9da57796e1eb91aa0ec5fa8948b732a47","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-2427] [streaming] Make the BarrierBuffer more robust against lost/missing checkpoint barriers.\n\nCheckpoint barriers are now tolerated to be lost (as may happen if the checkpoint triggering actor\nmessages are lost). This is realized by allowing the BarrierBuffer to maintain multiple queues of blocked inputs.\n\nThe patch also reworks the buffer spilling logic, to increase I/O efficiency, and reduce the main memory\nfootprint in cases where the buffers have little contents (low flush timeouts).","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/9311b9a9da57796e1eb91aa0ec5fa8948b732a47"},{"sha":"aa0105aa309da0dc8570b47880bb0624114e8231","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[runtime] Cleanup channel events. Add comments and move some classes to test scope.","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/aa0105aa309da0dc8570b47880bb0624114e8231"},{"sha":"af88aa09ec94d4d11f38a7134d36793420d7d19d","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-2438] [runtime] Improve channel event serialization performance.\n\nBecause channel events may become very frequent now (frequent at-least-once checkpointing), their serialization perfomance starts to matter.","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/af88aa09ec94d4d11f38a7134d36793420d7d19d"},{"sha":"40eef52e9f68c3c7727e9b9493959d5fd36d7f70","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[hotfix] [streaming] Fix race in stream tasks when canceling tasks early.","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/40eef52e9f68c3c7727e9b9493959d5fd36d7f70"},{"sha":"81f9b214a37aa81017eface6ba43f24f845a4ec8","author":{"email":"9bcb11ac70c2fc7872d9b58e21318011c5e228e2@gmail.com","name":"Sachin Goel"},"message":"[FLINK-2459] [cli] Cli API and doc fixes.\n\n1. Remove CliFrontendLoggingTest. Test directly that the logging flag is interpreted correctly.\n2. Doc fix for cli api\n3. Info command shouldn't print logging option for help.\n\nThis closes #971","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/81f9b214a37aa81017eface6ba43f24f845a4ec8"},{"sha":"b3dc3f050c125978f4fb14ccef230938e60a9198","author":{"email":"60744099747d34d187bbcfff35bedc8af6bafed7@gmail.com","name":"Enrique Bautista"},"message":"[FLINK-2463] [web dashboard] Shows job configuration in new dashboard\n\nThis closes #953","distinct":false,"url":"https://api.github.com/repos/sachingoel0101/flink/commits/b3dc3f050c125978f4fb14ccef230938e60a9198"}]}