{"push_id":820142347,"size":210,"distinct_size":210,"ref":"refs/heads/master","head":"0ee0c1f5573ad059dc6a8e4489094b7f78267306","before":"aec4b15755772a0a67105615e10859ead97260f3","commits":[{"sha":"407d74fd004bbd11febfa553c381e828115d8bfb","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-2647] [streaming core] Distinguish between \"close\" (flushing buffered data) and \"dispose\" (cleanup resources) in streaming operators.","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/407d74fd004bbd11febfa553c381e828115d8bfb"},{"sha":"a492ed922efd53c7f0545faf597ebf4cd291085f","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[hotfix] [tests] Fix warnings and casts in AbstractGenericArraySerializerTest","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/a492ed922efd53c7f0545faf597ebf4cd291085f"},{"sha":"635456890fe4d43a1c365d84ae45b5f34af056ce","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-2656] Fix behavior of FlinkKafkaConsumer for out of range offsets\n\nThis closes #1117","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/635456890fe4d43a1c365d84ae45b5f34af056ce"},{"sha":"b73fef24201048a6bec00d6083339534c59031df","author":{"email":"eb265d27286271bb2c2d5dc3b5127b74e175702a@gmail.com","name":"Behrouz Derakhshan"},"message":"[FLINK-2654] Add JavaDoc to ParameterTool class\n\nThis closes #1116","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/b73fef24201048a6bec00d6083339534c59031df"},{"sha":"8acd15d82f4d29088d0ecda5b74479ede48b84e3","author":{"email":"9dce984248492c9bcc6c6da7f0e57798f0e8f6c9@qq.com","name":"HuangWHWHW"},"message":"[streaming] Appropriate Exception message in WriteSinkFunction\n\nCloses #1119","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/8acd15d82f4d29088d0ecda5b74479ede48b84e3"},{"sha":"ce68cbd91621b1a58cb34b33ab27762c6525cfa0","author":{"email":"b36a4b8a3b519984e26e470684cfa9887ab74e9b@informatik.hu-berlin.de","name":"mjsax"},"message":"[FLINK-2658] fieldsGrouping for multiple output streams fails\n - added SplitStreamTypeKeySelector and JUnit tests\n\nThis closes #1122","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/ce68cbd91621b1a58cb34b33ab27762c6525cfa0"},{"sha":"8a75025abb229c8ebfa737525ed76c042379d7fd","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[FLINK-2664] [streaming] Allow partitioned state removal\n\nCloses #1126","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/8a75025abb229c8ebfa737525ed76c042379d7fd"},{"sha":"e78b80c4e4a99385ae5ef5a9afc9f8a64533a9e3","author":{"email":"a897ff0a4ead280bd50c297855249bede302ceb5@tu-berlin.de","name":"Andreas Kunft"},"message":"[FLINK-2373] Add configuration parameter to createRemoteEnvironment method\n\nThis closes #1066","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/e78b80c4e4a99385ae5ef5a9afc9f8a64533a9e3"},{"sha":"a75dd6270fd47720ae1c2ce9464ff6b8f7b43d39","author":{"email":"e6fb06210fafc02fd7479ddbed2d042cc3a5155e@greghogan.com","name":"Greg Hogan"},"message":"[FLINK-2655] Minimize intermediate merging of external merge sort.\n\nThis closes #1118","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/a75dd6270fd47720ae1c2ce9464ff6b8f7b43d39"},{"sha":"c923fb3c1c1d61462e1079198ae9fb735bb0acf2","author":{"email":"6cd8718626a16063cc3afa941dc9715c0845c635@126.com","name":"gallenvara"},"message":"[FLINK-2533] [java-api] Gap based random sample optimization.\n\nThis closes #1110","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/c923fb3c1c1d61462e1079198ae9fb735bb0acf2"},{"sha":"2cc5d98c690c1b1b1ff1f48628ca58b1b4f0c932","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[FLINK-2665] [api] [runtime] Makes ExecutionConfig serializable by forcing Kryo serializers to be Serializable\n\nThis closes #1128\n\n-----\nClosing PR:\nThis closes #867","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/2cc5d98c690c1b1b1ff1f48628ca58b1b4f0c932"},{"sha":"31f63178df2f81682527ba3debf9027bde78149b","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-2670] [tests] Add tests that validate memory release under concurrent modification exceptions","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/31f63178df2f81682527ba3debf9027bde78149b"},{"sha":"7bea90150309156536558d94cb5c244369af81b9","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-1851] [tableAPI] Add support for casting in Table Expression Parser\n- Also fix code generation for casting between primitives.\n- Extends documentation for TableAPI expressions\n\nThis closes #592","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/7bea90150309156536558d94cb5c244369af81b9"},{"sha":"a3150a3c3ac9b35ef6daf64ccf309498591483dd","author":{"email":"9dce984248492c9bcc6c6da7f0e57798f0e8f6c9@qq.com","name":"HuangWHWHW"},"message":"[TableAPI] [tests] Disambiguate result of test programs to DataSet\n\nThis closes #1131","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/a3150a3c3ac9b35ef6daf64ccf309498591483dd"},{"sha":"76a40d59e6623cfbc6e265d26da4e739e5e7ed18","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[FLINK-2641] integrate off-heap memory configuration\n- add offheap configuration parameter taskmanager.memory.off-heap\n- remove offheap ratio parameter and reuse memory fraction parameter\n- set JVM -XX:MaxDirectMemorySize parameter correctly\n\nThis closes #1129","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/76a40d59e6623cfbc6e265d26da4e739e5e7ed18"},{"sha":"2c9e2c8bbe1547709d820949d1739f7ea2ce89cf","author":{"email":"22f3e725b314afeca4d45e12683c560674029d21@gmail.com","name":"Ted"},"message":"[FLINK-2595] [tests] Fixed unclosed JarFile in ClassLoaderUtilsTest\n\nThis closes #1137","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/2c9e2c8bbe1547709d820949d1739f7ea2ce89cf"},{"sha":"8ca853e0f6c18be8e6b066c6ec0f23badb797323","author":{"email":"d7442c0ef41d7ba466873468445ae3e4cd8e3a42@apache.org","name":"Till Rohrmann"},"message":"[FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers\n- Fixes ObjectArrayTypeInfo\n- Makes CompositeTypes serializable\n- Adds test for equality relation's symmetric property\n- Adds test for PojoTypeInfo serializability\n\nThis closes #1134","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/8ca853e0f6c18be8e6b066c6ec0f23badb797323"},{"sha":"93c95b6a6f150a2c55dc387e4ef1d603b3ef3f22","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[FLINK-2640] [yarn] integrate off-heap configuration\n\nThis closes #1132","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/93c95b6a6f150a2c55dc387e4ef1d603b3ef3f22"},{"sha":"988a04eb486d286e071f4a68aa22c64a2cd4ed8e","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[FLINK-2689] [runtime] Fix reuse of null object for solution set Joins and CoGroups.\n\nThis closes #1136","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/988a04eb486d286e071f4a68aa22c64a2cd4ed8e"},{"sha":"c269158cc4ddb1faf79f75a2bf04aa5f9e1865bf","author":{"email":"e6fb06210fafc02fd7479ddbed2d042cc3a5155e@greghogan.com","name":"Greg Hogan"},"message":"[FLINK-2659] [runtime] Fix object reuse in UnionWithTempOperator\n\nThis closes #1130","distinct":true,"url":"https://api.github.com/repos/lofifnc/flink/commits/c269158cc4ddb1faf79f75a2bf04aa5f9e1865bf"}]}