Hi, My jira id is "flyisland", thanks! On Thu, Sep 27, 2018 at 3:25 AM Jean-Baptiste Onofré <[email protected]> wrote:
> Yes please. Create a jira, I will tackle that. Thanks. > > Regards > JB > Le 26 sept. 2018, à 15:12, Lukasz Cwik <[email protected]> a écrit: >> >> Yes, please create a JIRA account on issues.apache.org >> >> Once you have one, please tell my the JIRA id and I'll add you as a >> contributor to Apache Beam and assign BEAM-5496 to you. >> >> Also this guide https://beam.apache.org/contribute/ helps people learn >> how to contribute. It has useful information about how to build, test, open >> PRs, find reviewers. >> >> On Tue, Sep 25, 2018 at 9:37 PM flyisland <[email protected]> wrote: >> >>> Cool, I'd like to. >>> >>> Is there anything I should've done first, like create an account etc. >>> >>> On Tue, Sep 25, 2018 at 11:46 PM Lukasz Cwik <[email protected]> wrote: >>> >>>> Thanks, I filed https://issues.apache.org/jira/browse/BEAM-5496 with >>>> the details of your report. >>>> >>>> Would you be interested in submitting a patch with a test that >>>> exercises the bug? >>>> >>>> On Tue, Sep 25, 2018 at 1:21 AM flyisland <[email protected]> wrote: >>>> >>>>> Hi >>>>> >>>>> There is a bug of the built-in MqttIO, please check the < >>>>> https://github.com/apache/beam/blob/master/sdks/java/io/mqtt/src/main/java/org/apache/beam/sdk/io/mqtt/MqttIO.java#L336>, >>>>> this readObject() method forget to invoke the "stream.defaultReadObject()" >>>>> method. >>>>> >>>>> // set an empty list to messages when deserialize >>>>> private void readObject(java.io.ObjectInputStream stream) >>>>> throws IOException, ClassNotFoundException { >>>>> messages = new ArrayList<>(); >>>>> } >>>>> } >>>>> >>>>> So there is an exception while the runner tried to deserialize the >>>>> checkpoint object. >>>>> java.lang.RuntimeException: org.apache.beam.sdk.coders.CoderException: >>>>> 95 unexpected extra bytes after decoding >>>>> org.apache.beam.sdk.io.mqtt.MqttIO$MqttCheckpointMark@6764e219 at >>>>> org.apache.beam.runners.direct.DirectRunner$DirectPipelineResult.waitUntilFinish(DirectRunner.java:340) >>>>> ... >>>>> >>>>> >>>>> >>>>>
