{"push_id":1023055516,"size":164,"distinct_size":164,"ref":"refs/heads/master","head":"543c04949479191ddf4e7ec6035fce6a01e8c5a0","before":"cee135a85a63b6baee62aef1e87bc63a4bc414e3","commits":[{"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":true,"url":"https://api.github.com/repos/nikste/flink/commits/c97a63e3a5589e0a1040f67c81eb6e4e8ccde0ff"},{"sha":"41b826bda9f9c3cf95cb72a8af4127c255298ef0","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-3436] Remove ComplexIntegrationITCase","distinct":true,"url":"https://api.github.com/repos/nikste/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":true,"url":"https://api.github.com/repos/nikste/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":true,"url":"https://api.github.com/repos/nikste/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":true,"url":"https://api.github.com/repos/nikste/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":true,"url":"https://api.github.com/repos/nikste/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":true,"url":"https://api.github.com/repos/nikste/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":true,"url":"https://api.github.com/repos/nikste/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":true,"url":"https://api.github.com/repos/nikste/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":true,"url":"https://api.github.com/repos/nikste/flink/commits/8912fb06b9689589a57bb88c350cd65d18e50d02"},{"sha":"59f978f878ff30e1ca177d3fda11af803b59bb0b","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-3381] [runtime] Handle ConnectionLoss in ZooKeeper test util","distinct":true,"url":"https://api.github.com/repos/nikste/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":true,"url":"https://api.github.com/repos/nikste/flink/commits/a3b9d9717a7c0a09c2b9480588805915bad09761"},{"sha":"5aa7c254a5b6f38d7a7cab0893fc87efe6da9a44","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-3446] [runtime-web] Don't trigger back pressure sample for archived job\n\nThis closes #1673.","distinct":true,"url":"https://api.github.com/repos/nikste/flink/commits/5aa7c254a5b6f38d7a7cab0893fc87efe6da9a44"},{"sha":"5117bc650805b4f714ff17819826da84bf4cdd24","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[hotfox] Fix javadoc of getState to comply with constructor changes","distinct":true,"url":"https://api.github.com/repos/nikste/flink/commits/5117bc650805b4f714ff17819826da84bf4cdd24"},{"sha":"7f9ade46e873e5c59a1fbfa568ce3e8df8845443","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-3453] [runtime, runtime-web] Report partial stack trace sample for cleared tasks\n\nThis closes #1678.","distinct":true,"url":"https://api.github.com/repos/nikste/flink/commits/7f9ade46e873e5c59a1fbfa568ce3e8df8845443"},{"sha":"9bdee1b355c6113db35ba7476f65deffe5e39ea8","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[FLINK-3248] add constructor params and generic ConnectionFactory\n\nThis adds more default constructor parameters to the RMQSource. In addition,\nusers may override the setupConnectionFactory() method to return their onwn\nconfigured factory.\n\nThis closes #1670.","distinct":true,"url":"https://api.github.com/repos/nikste/flink/commits/9bdee1b355c6113db35ba7476f65deffe5e39ea8"},{"sha":"60d65ce741099910f582f3289e7cf3ed3a16899a","author":{"email":"180f55e8350155df1048ad760eeaa1cff137f014@apache.org","name":"Maximilian Michels"},"message":"[cleanup] remove RMQTopology file","distinct":true,"url":"https://api.github.com/repos/nikste/flink/commits/60d65ce741099910f582f3289e7cf3ed3a16899a"},{"sha":"9691d95244eb143db2e61955c5784293b3ab6b84","author":{"email":"5e4896e4185c162a2e84b9528cd53bff19819528@apache.org","name":"Ufuk Celebi"},"message":"[FLINK-3453] [runtime] Fix TaskManagerTest stability","distinct":true,"url":"https://api.github.com/repos/nikste/flink/commits/9691d95244eb143db2e61955c5784293b3ab6b84"},{"sha":"80c0c65b77eff388b8a30144fbac2a157a383bd4","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-3439] Remove final Long.MAX_VALUE Watermark in StreamSource","distinct":true,"url":"https://api.github.com/repos/nikste/flink/commits/80c0c65b77eff388b8a30144fbac2a157a383bd4"},{"sha":"bfc14ebc1e7d961095896a0230512be59b13537b","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-3450] Duplicate TypeSerializer in StateDescriptor.writeObject\n\nThe StateDescriptor can be serializer asynchronously in case of\nasynchronous checkpoints. In that case two threads would try to\nconcurrently use the TypeSerializer: The normal state updating and the\ncheckpoint serialization. If the TypeSerializer is a KryoSerializer this\ncan lead to problems. Therefore the need to duplicate it before using in\n\"writeObject\".","distinct":true,"url":"https://api.github.com/repos/nikste/flink/commits/bfc14ebc1e7d961095896a0230512be59b13537b"}]}