Yes please. Create a jira, I will tackle that. Thanks. Regards JB
Le 26 sept. 2018 à 15:12, à 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) >>>> ... >>>> >>>> >>>> >>>>
