GitHub user jkff opened a pull request:
https://github.com/apache/incubator-beam/pull/1584
DO NOT REVIEW. Debugging MqttIO failures.
(can't reproduce the error locally, and don't know how to run something on
Travis - so creating a PR just for the sake of getting a Travis run)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/jkff/incubator-beam mqttio-test
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-beam/pull/1584.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1584
----
commit 234916835fcd83a3a43409e81c94880d0988dde9
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Date: 2016-09-12T16:49:36Z
[BEAM-606] Create MqttIO
commit 6ed144825fcfc978103c5cc8c96546ae283f86b2
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Date: 2016-09-23T21:27:40Z
[BEAM-606] Use AutoValue, remove checkpoint, introduce BlockingQueue and
improve tests.
commit 9fbee3fc87f92d2bd43d5dc79cc277d8e648ebb4
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Date: 2016-10-05T10:28:44Z
[BEAM-606] Set topic required. Move some subscriber specific MQTT code on
the reader. Improve tests.
commit 6f4713006f9062f42bad9643ce9dbf115c7af119
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Date: 2016-10-05T14:46:24Z
[BEAM-606] Replace KV internal use with a regular POJO
commit 6bb48572c8cb2099d3782de5465eddade0ff3326
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Date: 2016-10-05T14:55:43Z
[BEAM-606] Use a better value for watermark
commit e02b2a25d4698eafda492192c339246db9f670af
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Date: 2016-10-10T19:12:37Z
[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
commit 775a066625f5f250404ad2571aabf6e278aed662
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Date: 2016-10-13T07:44:00Z
[BEAM-606] Rename connection configuration, improve javadoc
commit 352b5fb279fe7dfd2d5a80bc023cbe7c2106eb1c
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Date: 2016-10-13T08:41:52Z
[BEAM-606] Refactore read test to be more reliable
commit 42ff71deaf0bdedf9ee62f25d21aeb5efff2ec9b
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Date: 2016-10-21T13:50:44Z
[BEAM-606] Update documentation, change the QoS in the test
commit 532704604658ac081eb16611958e4ad7419b6855
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Date: 2016-11-02T06:01:39Z
[BEAM-606] Start ActiveMQ broker on free network port in the tests
commit dda9092d1e2fb17c80641d3490de5a7d4ae242a5
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Date: 2016-11-02T09:38:55Z
[BEAM-606] Fix parent pom version
commit b92eb296a8755f2f92bbfa3f1ad9acc12d6ea080
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Date: 2016-11-03T08:50:00Z
[BEAM-606] Exclude support of QoS 2, cleanup in javadoc
commit 75d24726ec9ffb71844c760a3f321ebab0e7a228
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Date: 2016-11-14T12:07:01Z
[BEAM-606] Add core MQTT test
commit fc1195ad917144ed2ac829ea8f8c3df620e0cbb4
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Date: 2016-11-22T16:58:14Z
[BEAM-606] Improved checkpoint with manual ack, update comments about QoS
(relationship between publisher and subsribers), auto generate clientId
(reliability)
commit f7063fbc9343101a921715082b7cc06da0184483
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Date: 2016-12-05T10:14:41Z
[BEAM-606] Fix checkpoint mark
commit 7d9b9cdcd155cdd35082095887728afa9372e500
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Date: 2016-12-09T17:14:07Z
[BEAM-606] Only support QoS 1 in Write, updated to last SDK changes
commit aed01b9696f2bb87eb01d8477b2d322b24fb7119
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Date: 2016-12-10T15:56:35Z
[BEAM-606] Use ActiveMQ KahaDB in test for persistence adapter
commit e77fea21d065cf926506c1a49f05f3c9d7101d21
Author: Eugene Kirpichov <kirpic...@google.com>
Date: 2016-12-12T22:04:26Z
For debugging: dont drop stack in UserCodeException
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
