{"push_id":987882422,"size":29,"distinct_size":1,"ref":"refs/heads/slotsharing-fix","head":"5cb0cdd69b529ed5cd0a949f6def44e37a7cb325","before":"f1c0f34cfa50485b02151f59d8c5c60f57157037","commits":[{"sha":"50a166df3e96d4783a5ee35aefe07cfaea5927e6","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-3299] Remove ApplicationID from Environment\n\nThis closes #1642.","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/50a166df3e96d4783a5ee35aefe07cfaea5927e6"},{"sha":"97d1f4a1c9255af86c68e63dbe1712ace9d7bb01","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[hotfix] Fixes to flink-annotations JavaDocs","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/97d1f4a1c9255af86c68e63dbe1712ace9d7bb01"},{"sha":"bd137aec4a29ad1de4201245dd17d8f759e13f29","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[hotfix] Properly declare ComplexIntegrationTest as an Integration Test Case","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/bd137aec4a29ad1de4201245dd17d8f759e13f29"},{"sha":"6dda5316f6ad60cae877f15b24bc056638de7fc8","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-3413] [streaming] Make implicit conversions from Java DataStream to Scala DataStream explicit\n\nThis also clean up a lot of JavaDocs in various Scala DataStream API classes.","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/6dda5316f6ad60cae877f15b24bc056638de7fc8"},{"sha":"a8afec3b55700362ee76b8d5c6855819e0a27818","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-3421] [streaming scala] Remove unneeded ClassTag context bounds","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/a8afec3b55700362ee76b8d5c6855819e0a27818"},{"sha":"06a42bf6d64734621cc6aa92d5823d935c07e02c","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-3419] [streaming] Drop 'partitionByHash' function, subsumed by 'keyBy()'","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/06a42bf6d64734621cc6aa92d5823d935c07e02c"},{"sha":"a4e8fcbe9e3eacda822282e8a7dfbc5d74d79b34","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[hotfix] Auto-select actor system port in TestingCluster to prevent port collisions","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/a4e8fcbe9e3eacda822282e8a7dfbc5d74d79b34"},{"sha":"cee135a85a63b6baee62aef1e87bc63a4bc414e3","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-3430] Remove \"no POJO\" warning in TypeAnalyzer\n\nThis closes #1655","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/cee135a85a63b6baee62aef1e87bc63a4bc414e3"},{"sha":"c97a63e3a5589e0a1040f67c81eb6e4e8ccde0ff","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-3400] Move RocksDB Copy Utils to flink-streaming-java\n\nThey are not specific to RocksDB, just utilities for copying local\nfolders to/from HDFS. Moving them to flink-streaming-java means that\nthey are always in the classpath of the TaskManager, not only in the\nuser-code jar when using RocksDB. If they are only in the user-code jar\nthe external process runner cannot find the class files, leading to\nClassNotFoundExceptions.","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/c97a63e3a5589e0a1040f67c81eb6e4e8ccde0ff"},{"sha":"41b826bda9f9c3cf95cb72a8af4127c255298ef0","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-3436] Remove ComplexIntegrationITCase","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/41b826bda9f9c3cf95cb72a8af4127c255298ef0"},{"sha":"06e3dd1338efba2b40fde8c82a9c1f3e34476baf","author":{"email":"f6773562c9b47f90844286155b23bf8af2851ee5@web.de","name":"zentol"},"message":"[FLINK-3423] [tests] Fixed ExternalProcessRunnerTest on Windows\n\nThis closes #1650","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/06e3dd1338efba2b40fde8c82a9c1f3e34476baf"},{"sha":"7278e875bd57712a3a5c6069eac491834684c3bf","author":{"email":"f6773562c9b47f90844286155b23bf8af2851ee5@web.de","name":"zentol"},"message":"[FLINK-3424] [tests] Close InputStream in FileStateBackendTest#validateBytesInStream\n\nThis closes #1653","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/7278e875bd57712a3a5c6069eac491834684c3bf"},{"sha":"138334a6d0181de153abd9bcfabba201ad512f34","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[hotfix] [tests] Increase timeouts in WebFrontendITCase for stability on CI infrastructure","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/138334a6d0181de153abd9bcfabba201ad512f34"},{"sha":"0c6c723faf7196109bb331cd5e36b48d62534bc7","author":{"email":"6873ed71afbc9d34f235a1376a902115740ccfeb@apache.org","name":"vasia"},"message":"[docs] fix typos in quickstart and CEP docs\n\nThis closes #1663","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/0c6c723faf7196109bb331cd5e36b48d62534bc7"},{"sha":"d48bb59a572bf06e7a22c2fd4a2bc232ab8b6925","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-3368][Kafka 0.8] Handle leader changes in Kafka Consumer.","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/d48bb59a572bf06e7a22c2fd4a2bc232ab8b6925"},{"sha":"3a8717fd6e569a7b91d4265de109663a6c53d7ab","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-3386] Ensure Flink Kafka 0.8 is correctly using 'auto.offset.reset'","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/3a8717fd6e569a7b91d4265de109663a6c53d7ab"},{"sha":"0b7c2db76fd25b5cde7c14c7eb906c308a4ecfb9","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-3368][Kafka 0.8] Some improvements to the Legacy Fetcher","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/0b7c2db76fd25b5cde7c14c7eb906c308a4ecfb9"},{"sha":"8912fb06b9689589a57bb88c350cd65d18e50d02","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-3386][FLINK-3368][Kafka 0.8] Cleanup Kafka Connector\n\n- Remove Guava dependency\n- Remove unused methods\n- Move ZKString Serializer\n- Add user-friendly error messages when parsing arguments\n\nThis closes #1623 and closes #1672","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/8912fb06b9689589a57bb88c350cd65d18e50d02"},{"sha":"59f978f878ff30e1ca177d3fda11af803b59bb0b","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-3381] [runtime] Handle ConnectionLoss in ZooKeeper test util","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/59f978f878ff30e1ca177d3fda11af803b59bb0b"},{"sha":"a3b9d9717a7c0a09c2b9480588805915bad09761","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[tests] Try to improve CI test stability\n\nSquashes the following commits:\n- [tests] Wait for task managers in JobManagerFailsITCase\n  Possible fix for: https://s3.amazonaws.com/archive.travis-ci.org/jobs/110235128/log.txt\n- [tests] Move ITCase from runtime to tests\n- [tests] Merge abstract and sub type class\n- [tests] Determine JobManagerProcess ports from logs\n\nThis closes #1676.","distinct":false,"url":"https://api.github.com/repos/aljoscha/flink/commits/a3b9d9717a7c0a09c2b9480588805915bad09761"}]}