[
https://issues.apache.org/jira/browse/BEAM-1829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972381#comment-15972381
]
ASF GitHub Bot commented on BEAM-1829:
--------------------------------------
GitHub user vascokk opened a pull request:
https://github.com/apache/beam/pull/2572
[BEAM-1829] MQTT not working on ARM devices
This fixes BEAM-1829. Updated snappy-java version.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [x] Make sure the PR title is formatted like:
`[BEAM-<Jira issue #>] Description of pull request`
- [x] Make sure tests pass via `mvn clean verify`. (Even better, enable
Travis-CI on your fork and ensure the whole test matrix passes).
- [x] Replace `<Jira issue #>` in the title with the actual Jira issue
number, if there is one.
- [ ] If this contribution is large, please file an Apache
[Individual Contributor License
Agreement](https://www.apache.org/licenses/icla.pdf).
---
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vascokk/beam master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/beam/pull/2572.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2572
----
commit 45975008363d243d09502c7213a25c3486595d7e
Author: Vassil Kolarov <[email protected]>
Date: 2017-03-29T14:02:36Z
Changed snappy version to 1.1.4-M3
commit a9b4ad06eff47b2fc033122f4160f0519ee9491b
Author: Vassil Kolarov <[email protected]>
Date: 2017-03-29T14:02:36Z
Changed snappy version to 1.1.4-M3
commit bc0936ed6c431fc7d4a8a91afb09d25009b6f8d4
Author: Vassil Kolarov <[email protected]>
Date: 2017-03-29T15:47:56Z
Merge branch 'master' of github.com:vascokk/beam
commit 446a46a7e6db6b043bb08ef6d71a4f90f91a43e7
Author: Vassil Kolarov <[email protected]>
Date: 2017-04-03T13:59:36Z
Merge remote-tracking branch 'upstream/master'
commit d03ea27a61715ce30dde626b425eeeb98a8efe9a
Author: Vassil Kolarov <[email protected]>
Date: 2017-04-18T08:18:28Z
Merge remote-tracking branch 'upstream/master'
----
> 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é
> Labels: MQTT, Snappy
>
> Most probably due to this bug:
> https://github.com/xerial/snappy-java/issues/147, the following exception is
> raised, when running on Raspberry Pi:
> Exception in thread "main" java.lang.UnsatisfiedLinkError:
> /root/~/tmp/snappy-1.1.2-3c6134d1-26c5-4fb0-b6c9-669d4848d15b-libsnappyjava.so:
> /root/~/tmp/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.serializeToByteArray(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(PipelineRunner.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)
