You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by jb...@apache.org on 2019/10/12 05:50:14 UTC

[beam] branch master updated (2ff462d -> 5a851b7)

This is an automated email from the ASF dual-hosted git repository.

jbonofre pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 2ff462d  Merge pull request #9752: [BEAM-8183] restructure Flink portable jars to support multiple pipelines
     new 7f66522  fix for message being not serializable due to LongString in headers
     new 05db193  [BEAM-7414] applying Beam project style guides (or trying so)
     new 3c845cb  [BEAM-7414] Fixing test failures : seems like generated test messages have no header values, which made LongString-elimination code failing
     new 36d289b  Seems like i changed that line by error. Rolling that back.
     new 51fabee  That code was useless Indeed, if there is an IOException when trying to ack the message, there most probably be one when trying to nack the message.
     new 5252a20  According to jbonofre, the transformation of deliverable into serializable objects lies in RabbitMqMessage And i agree, it's way better.
     new d8d8761  fixed one last formatting point
     new 5a851b7  Merge pull request #8677 from Riduidel/fix/rabbitmq-message-not-serializable

The 23451 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../apache/beam/sdk/io/rabbitmq/RabbitMqIO.java    |  4 +-
 .../beam/sdk/io/rabbitmq/RabbitMqMessage.java      | 66 ++++++++++++++++++++++
 2 files changed, 68 insertions(+), 2 deletions(-)