Thanks, I assigned BEAM-5496. Feel free to ask questions on dev@ as needed.
On Wed, Sep 26, 2018 at 7:11 PM flyisland <[email protected]> wrote: > 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) >>>>>> ... >>>>>> >>>>>> >>>>>> >>>>>>
