Mailing-List: contact commits-help@beam.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@beam.apache.org
Date: Thu, 30 Mar 2017 04:12:41 +0000 (UTC)
From: =?utf-8?Q?Jean-Baptiste_Onofr=C3=A9_=28JIRA=29?= <jira@apache.org>
To: commits@beam.apache.org
Message-ID: <JIRA.13060062.1490799314000.161360.1490847161657@Atlassian.JIRA>
In-Reply-To: <JIRA.13060062.1490799314000@Atlassian.JIRA>
References: <JIRA.13060062.1490799314000@Atlassian.JIRA> <JIRA.13060062.1490799314325@jira-lw-us.apache.org>
Subject: [jira] [Commented] (BEAM-1829) MQTT message compression not working
 on Rapsberry Pi
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: quoted-printable
archived-at: Thu, 30 Mar 2017 04:12:47 -0000


    [ https://issues.apache.org/jira/browse/BEAM-1829?page=3Dcom.atlassian.=
jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=3D15948=
391#comment-15948391 ]=20

Jean-Baptiste Onofr=C3=A9 commented on BEAM-1829:
--------------------------------------------

Happy to review !

> MQTT message compression not working on Rapsberry Pi
> ----------------------------------------------------
>
>                 Key: BEAM-1829
>                 URL: https://issues.apache.org/jira/browse/BEAM-1829
>             Project: Beam
>          Issue Type: Improvement
>          Components: sdk-java-extensions
>    Affects Versions: 0.6.0
>            Reporter: Vassil Kolarov
>            Assignee: Jean-Baptiste Onofr=C3=A9
>              Labels: MQTT, Snappy
>
> Most probably due to this bug: https://github.com/xerial/snappy-java/issu=
es/147, the following exception is raised, when running on Raspberry Pi:
> Exception in thread "main" java.lang.UnsatisfiedLinkError: /root/~/tmp/sn=
appy-1.1.2-3c6134d1-26c5-4fb0-b6c9-669d4848d15b-libsnappyjava.so: /root/~/t=
mp/snappy-1.1.2-3c6134d1-26c5-4fb0-b6c9-669d4848d15b-libsn
> appyjava.so: cannot open shared object file: No such file or directory
>         at java.lang.ClassLoader$NativeLibrary.load(Native Method)
>         at java.lang.ClassLoader.loadLibrary0(ClassLoader.java:1929)
>         at java.lang.ClassLoader.loadLibrary(ClassLoader.java:1814)
>         at java.lang.Runtime.load0(Runtime.java:809)
>         at java.lang.System.load(System.java:1083)
>         at org.xerial.snappy.SnappyLoader.loadNativeLibrary(SnappyLoader.=
java:174)
>         at org.xerial.snappy.SnappyLoader.load(SnappyLoader.java:152)
>         at org.xerial.snappy.Snappy.<clinit>(Snappy.java:46)
>         at org.xerial.snappy.SnappyOutputStream.<init>(SnappyOutputStream=
.java:97)
>         at org.xerial.snappy.SnappyOutputStream.<init>(SnappyOutputStream=
.java:89)
>         at org.xerial.snappy.SnappyOutputStream.<init>(SnappyOutputStream=
.java:79)
>         at org.apache.beam.sdk.util.SerializableUtils.serializeToByteArra=
y(SerializableUtils.java:48)
>         at org.apache.beam.sdk.util.SerializableUtils.ensureSerializable(=
SerializableUtils.java:83)
>         at org.apache.beam.sdk.io.Read$Unbounded.<init>(Read.java:141)
>         at org.apache.beam.sdk.io.Read$Unbounded.<init>(Read.java:136)
>         at org.apache.beam.sdk.io.Read.from(Read.java:56)
>         at org.apache.beam.sdk.io.mqtt.MqttIO$Read.expand(MqttIO.java:274=
)
>         at org.apache.beam.sdk.io.mqtt.MqttIO$Read.expand(MqttIO.java:221=
)
>         at org.apache.beam.sdk.runners.PipelineRunner.apply(PipelineRunne=
r.java:76)
>         at org.apache.beam.runners.direct.DirectRunner.apply(DirectRunner=
.java:296)
>         at org.apache.beam.sdk.Pipeline.applyInternal(Pipeline.java:388)
>         at org.apache.beam.sdk.Pipeline.applyTransform(Pipeline.java:302)
>         at org.apache.beam.sdk.values.PBegin.apply(PBegin.java:47)
>         at org.apache.beam.sdk.Pipeline.apply(Pipeline.java:152)
>         at org.blah.beam.MqttPipeline.main(MqttPipeline.java:37)
> Increasing the snappy version to 1.1.4 will probably fix the issue.
> Best regards,
> Vassil


--
This message was sent by Atlassian JIRA
(v6.3.15#6346)