beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jkff <>
Subject [GitHub] incubator-beam pull request #1584: DO NOT REVIEW. Debugging MqttIO failures.
Date Mon, 12 Dec 2016 22:06:31 GMT
GitHub user jkff opened a pull request:

    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 mqttio-test

Alternatively you can review and apply these changes as the patch at:

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é <>
Date:   2016-09-12T16:49:36Z

    [BEAM-606] Create MqttIO

commit 6ed144825fcfc978103c5cc8c96546ae283f86b2
Author: Jean-Baptiste Onofré <>
Date:   2016-09-23T21:27:40Z

    [BEAM-606] Use AutoValue, remove checkpoint, introduce BlockingQueue and improve tests.

commit 9fbee3fc87f92d2bd43d5dc79cc277d8e648ebb4
Author: Jean-Baptiste Onofré <>
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é <>
Date:   2016-10-05T14:46:24Z

    [BEAM-606] Replace KV internal use with a regular POJO

commit 6bb48572c8cb2099d3782de5465eddade0ff3326
Author: Jean-Baptiste Onofré <>
Date:   2016-10-05T14:55:43Z

    [BEAM-606] Use a better value for watermark

commit e02b2a25d4698eafda492192c339246db9f670af
Author: Jean-Baptiste Onofré <>
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é <>
Date:   2016-10-13T07:44:00Z

    [BEAM-606] Rename connection configuration, improve javadoc

commit 352b5fb279fe7dfd2d5a80bc023cbe7c2106eb1c
Author: Jean-Baptiste Onofré <>
Date:   2016-10-13T08:41:52Z

    [BEAM-606] Refactore read test to be more reliable

commit 42ff71deaf0bdedf9ee62f25d21aeb5efff2ec9b
Author: Jean-Baptiste Onofré <>
Date:   2016-10-21T13:50:44Z

    [BEAM-606] Update documentation, change the QoS in the test

commit 532704604658ac081eb16611958e4ad7419b6855
Author: Jean-Baptiste Onofré <>
Date:   2016-11-02T06:01:39Z

    [BEAM-606] Start ActiveMQ broker on free network port in the tests

commit dda9092d1e2fb17c80641d3490de5a7d4ae242a5
Author: Jean-Baptiste Onofré <>
Date:   2016-11-02T09:38:55Z

    [BEAM-606] Fix parent pom version

commit b92eb296a8755f2f92bbfa3f1ad9acc12d6ea080
Author: Jean-Baptiste Onofré <>
Date:   2016-11-03T08:50:00Z

    [BEAM-606] Exclude support of QoS 2, cleanup in javadoc

commit 75d24726ec9ffb71844c760a3f321ebab0e7a228
Author: Jean-Baptiste Onofré <>
Date:   2016-11-14T12:07:01Z

    [BEAM-606] Add core MQTT test

commit fc1195ad917144ed2ac829ea8f8c3df620e0cbb4
Author: Jean-Baptiste Onofré <>
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é <>
Date:   2016-12-05T10:14:41Z

    [BEAM-606] Fix checkpoint mark

commit 7d9b9cdcd155cdd35082095887728afa9372e500
Author: Jean-Baptiste Onofré <>
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é <>
Date:   2016-12-10T15:56:35Z

    [BEAM-606] Use ActiveMQ KahaDB in test for persistence adapter

commit e77fea21d065cf926506c1a49f05f3c9d7101d21
Author: Eugene Kirpichov <>
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 or file a JIRA ticket
with INFRA.

View raw message