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) >>> ... >>> >>> >>> >>>
