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

Posted to commits@beam.apache.org by ie...@apache.org on 2018/05/23 20:29:36 UTC

[beam] 01/01: Merge pull request #5422 from timrobertson100/BEAM-4347

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

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

commit e31f27f51c7ca413c7637d71d5c717af6a54281e
Merge: 8345991 585547a
Author: Ismaël Mejía <ie...@gmail.com>
AuthorDate: Wed May 23 22:29:31 2018 +0200

    Merge pull request #5422 from timrobertson100/BEAM-4347
    
    [BEAM-4347] Enforce ErrorProne analysis in kafka IO

 sdks/java/io/kafka/build.gradle                           |  4 +++-
 .../apache/beam/sdk/io/kafka/KafkaExactlyOnceSink.java    | 12 ++++++++++--
 .../main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java   |  1 +
 .../apache/beam/sdk/io/kafka/KafkaUnboundedReader.java    | 15 ++++++++++-----
 .../java/org/apache/beam/sdk/io/kafka/KafkaWriter.java    |  2 ++
 .../kafka/CustomTimestampPolicyWithLimitedDelayTest.java  |  2 +-
 .../java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java    | 12 +++++++-----
 .../apache/beam/sdk/io/kafka/KafkaRecordCoderTest.java    |  3 ++-
 8 files changed, 36 insertions(+), 15 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
iemejia@apache.org.