{"push_id":1457241598,"size":27,"distinct_size":27,"ref":"refs/heads/BEAM-606-MQTTIO","head":"d01f963ced9687e8d4c4d74250876be8772b2cd6","before":"e2b7482d30e57b917c9ae6965ee387e765afbb49","commits":[{"sha":"b626f0e627af85b2aa01213587b4130932030166","author":{"name":"Mark Liu","email":"96a77986cc5fa89f49b6f0ac2d1cb48fc4603020@markliu-macbookpro.roam.corp.google.com"},"message":"[BEAM-1033] Retry Bigquery Verifier when Query Fails\n\nUpdate Junit to 4.12","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/b626f0e627af85b2aa01213587b4130932030166"},{"sha":"0b0a1b79794598478033105e0582650fe17953ac","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"This closes #1479","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/0b0a1b79794598478033105e0582650fe17953ac"},{"sha":"00b961df2e6086ea9f5cb8b9b8fb747739d33670","author":{"name":"Kenneth Knowles","email":"7ee59cbbb0cfc706bc0a9605e2d68fae3354c025@google.com"},"message":"Fix NPE in StatefulParDoEvaluatorFactoryTest mocking","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/00b961df2e6086ea9f5cb8b9b8fb747739d33670"},{"sha":"9fbf429b20d946d87098c372a2ae6bb3becca083","author":{"name":"Kenneth Knowles","email":"7ee59cbbb0cfc706bc0a9605e2d68fae3354c025@google.com"},"message":"This closes #1618","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/9fbf429b20d946d87098c372a2ae6bb3becca083"},{"sha":"028408f5a9955879f03e5bb65c54813922ee4672","author":{"name":"Pei He","email":"17c994c0b8f5c9ef72564c0b717afcb0ddc06269@google.com"},"message":"[BEAM-1153] GcsUtil: use non-batch API for single file size requests.","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/028408f5a9955879f03e5bb65c54813922ee4672"},{"sha":"46566fc71aad7cb3937bc764ff88510c7c0fa666","author":{"name":"Dan Halperin","email":"0291491adc84a7497e89df29893a36b10448bbd8@google.com"},"message":"Closes #1611","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/46566fc71aad7cb3937bc764ff88510c7c0fa666"},{"sha":"cf4229a6d7e1b79416a1be4e78f5c90c38dd77b0","author":{"name":"Scott Wegner","email":"33f9eae64f7ae31295cdf43ca21ada514ccfbd0e@google.com"},"message":"Fail to split in FileBasedSource if filePattern expands to empty.\n\nTypically, input file patterns are validated during Pipeline\nconstruction, but standard Read transforms include an option to disable\nvalidation. This is generally useful but can lead to cases where a\nPipeline executes successfully with empty inputs.\n\nThis changes the behavior to fail execution on empty file-based inputs\neven when validation is disabled.","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/cf4229a6d7e1b79416a1be4e78f5c90c38dd77b0"},{"sha":"1ad638e514adda6dc6d4c2133d47a3434a565410","author":{"name":"Dan Halperin","email":"0291491adc84a7497e89df29893a36b10448bbd8@google.com"},"message":"Closes #1621","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/1ad638e514adda6dc6d4c2133d47a3434a565410"},{"sha":"2adc72eba8243fab11da083dfd1cdcf86e368d7a","author":{"name":"Jean-Baptiste Onofré","email":"15f971fe3505ad4c5b59d5f7e374a55a4f1e4fe8@apache.org"},"message":"[BEAM-606] Create MqttIO","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/2adc72eba8243fab11da083dfd1cdcf86e368d7a"},{"sha":"a7acb9ff89482dc01173d300a7ef67c049a4ae9e","author":{"name":"Jean-Baptiste Onofré","email":"15f971fe3505ad4c5b59d5f7e374a55a4f1e4fe8@apache.org"},"message":"[BEAM-606] Use AutoValue, remove checkpoint, introduce BlockingQueue and improve tests.","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/a7acb9ff89482dc01173d300a7ef67c049a4ae9e"},{"sha":"f243c0a8682043e3a5533ffdb3dd501c6e8ffebb","author":{"name":"Jean-Baptiste Onofré","email":"15f971fe3505ad4c5b59d5f7e374a55a4f1e4fe8@apache.org"},"message":"[BEAM-606] Set topic required. Move some subscriber specific MQTT code on the reader. Improve tests.","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/f243c0a8682043e3a5533ffdb3dd501c6e8ffebb"},{"sha":"1067ef4a4d37d27f5be869ef71649dc794dbfb25","author":{"name":"Jean-Baptiste Onofré","email":"15f971fe3505ad4c5b59d5f7e374a55a4f1e4fe8@apache.org"},"message":"[BEAM-606] Replace KV internal use with a regular POJO","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/1067ef4a4d37d27f5be869ef71649dc794dbfb25"},{"sha":"a943beaf635bccb04310d31e2728ae8fc8615754","author":{"name":"Jean-Baptiste Onofré","email":"15f971fe3505ad4c5b59d5f7e374a55a4f1e4fe8@apache.org"},"message":"[BEAM-606] Use a better value for watermark","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/a943beaf635bccb04310d31e2728ae8fc8615754"},{"sha":"3919bd39c38eea0146f1cae62255f2ffbef239ef","author":{"name":"Jean-Baptiste Onofré","email":"15f971fe3505ad4c5b59d5f7e374a55a4f1e4fe8@apache.org"},"message":"[BEAM-606] Validation is now performed only in create(), maxNumRecords and maxReadTime are now exclusive, use ByteArrayCoder instead of SerializableCoder, use poll instead of take on the blocking queue, add javadoc on the with* methods, code cleanup","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/3919bd39c38eea0146f1cae62255f2ffbef239ef"},{"sha":"5626e75d8e48fc9c4943246b9959fab4253e0deb","author":{"name":"Jean-Baptiste Onofré","email":"15f971fe3505ad4c5b59d5f7e374a55a4f1e4fe8@apache.org"},"message":"[BEAM-606] Rename connection configuration, improve javadoc","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/5626e75d8e48fc9c4943246b9959fab4253e0deb"},{"sha":"3403567262b12ee3230f202474ddf4b02346105a","author":{"name":"Jean-Baptiste Onofré","email":"15f971fe3505ad4c5b59d5f7e374a55a4f1e4fe8@apache.org"},"message":"[BEAM-606] Refactore read test to be more reliable","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/3403567262b12ee3230f202474ddf4b02346105a"},{"sha":"7ef47e7df7b060f452cc496c8dd4bc3b322052f7","author":{"name":"Jean-Baptiste Onofré","email":"15f971fe3505ad4c5b59d5f7e374a55a4f1e4fe8@apache.org"},"message":"[BEAM-606] Update documentation, change the QoS in the test","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/7ef47e7df7b060f452cc496c8dd4bc3b322052f7"},{"sha":"e075defad8d8fa1aa5372dac52fb3a286374163b","author":{"name":"Jean-Baptiste Onofré","email":"15f971fe3505ad4c5b59d5f7e374a55a4f1e4fe8@apache.org"},"message":"[BEAM-606] Start ActiveMQ broker on free network port in the tests","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/e075defad8d8fa1aa5372dac52fb3a286374163b"},{"sha":"d168ff0162ec1422f9d855e40bd6a029a0528f49","author":{"name":"Jean-Baptiste Onofré","email":"15f971fe3505ad4c5b59d5f7e374a55a4f1e4fe8@apache.org"},"message":"[BEAM-606] Fix parent pom version","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/d168ff0162ec1422f9d855e40bd6a029a0528f49"},{"sha":"5ed045336c3372a04446746ba97264897b61dedc","author":{"name":"Jean-Baptiste Onofré","email":"15f971fe3505ad4c5b59d5f7e374a55a4f1e4fe8@apache.org"},"message":"[BEAM-606] Exclude support of QoS 2, cleanup in javadoc","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/5ed045336c3372a04446746ba97264897b61dedc"}]}
{"actor":{"display_login":"jbonofre"}}