You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jkff <gi...@git.apache.org> on 2016/12/12 22:06:31 UTC
[GitHub] incubator-beam pull request #1584: DO NOT REVIEW. Debugging MqttIO failures.
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� <jb...@apache.org>
Date: 2016-09-12T16:49:36Z
[BEAM-606] Create MqttIO
commit 6ed144825fcfc978103c5cc8c96546ae283f86b2
Author: Jean-Baptiste Onofr� <jb...@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� <jb...@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� <jb...@apache.org>
Date: 2016-10-05T14:46:24Z
[BEAM-606] Replace KV internal use with a regular POJO
commit 6bb48572c8cb2099d3782de5465eddade0ff3326
Author: Jean-Baptiste Onofr� <jb...@apache.org>
Date: 2016-10-05T14:55:43Z
[BEAM-606] Use a better value for watermark
commit e02b2a25d4698eafda492192c339246db9f670af
Author: Jean-Baptiste Onofr� <jb...@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� <jb...@apache.org>
Date: 2016-10-13T07:44:00Z
[BEAM-606] Rename connection configuration, improve javadoc
commit 352b5fb279fe7dfd2d5a80bc023cbe7c2106eb1c
Author: Jean-Baptiste Onofr� <jb...@apache.org>
Date: 2016-10-13T08:41:52Z
[BEAM-606] Refactore read test to be more reliable
commit 42ff71deaf0bdedf9ee62f25d21aeb5efff2ec9b
Author: Jean-Baptiste Onofr� <jb...@apache.org>
Date: 2016-10-21T13:50:44Z
[BEAM-606] Update documentation, change the QoS in the test
commit 532704604658ac081eb16611958e4ad7419b6855
Author: Jean-Baptiste Onofr� <jb...@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� <jb...@apache.org>
Date: 2016-11-02T09:38:55Z
[BEAM-606] Fix parent pom version
commit b92eb296a8755f2f92bbfa3f1ad9acc12d6ea080
Author: Jean-Baptiste Onofr� <jb...@apache.org>
Date: 2016-11-03T08:50:00Z
[BEAM-606] Exclude support of QoS 2, cleanup in javadoc
commit 75d24726ec9ffb71844c760a3f321ebab0e7a228
Author: Jean-Baptiste Onofr� <jb...@apache.org>
Date: 2016-11-14T12:07:01Z
[BEAM-606] Add core MQTT test
commit fc1195ad917144ed2ac829ea8f8c3df620e0cbb4
Author: Jean-Baptiste Onofr� <jb...@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� <jb...@apache.org>
Date: 2016-12-05T10:14:41Z
[BEAM-606] Fix checkpoint mark
commit 7d9b9cdcd155cdd35082095887728afa9372e500
Author: Jean-Baptiste Onofr� <jb...@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� <jb...@apache.org>
Date: 2016-12-10T15:56:35Z
[BEAM-606] Use ActiveMQ KahaDB in test for persistence adapter
commit e77fea21d065cf926506c1a49f05f3c9d7101d21
Author: Eugene Kirpichov <ki...@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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] incubator-beam pull request #1584: DO NOT REVIEW. Debugging MqttIO failures.
Posted by jkff <gi...@git.apache.org>.
Github user jkff closed the pull request at:
https://github.com/apache/incubator-beam/pull/1584
---
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---