You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2022/06/17 16:48:04 UTC
[beam] branch master updated (b5ea07d77c0 -> 3a6100d7af5)
This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from b5ea07d77c0 Consider skipped checks successful (#21924)
add 992d4c08ade Suppress unneeded spotbugs unused store warnings
add 152bcde49e4 Eliminate nullness errors in KafkaIO
new 3a6100d7af5 Merge pull request #21783: Eliminate nullness errors in KafkaIO
The 1 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:
.../src/main/resources/beam/spotbugs-filter.xml | 7 +
.../src/main/java/org/apache/beam/sdk/io/Read.java | 5 +-
...onfluentSchemaRegistryDeserializerProvider.java | 22 +--
.../beam/sdk/io/kafka/KafkaCheckpointMark.java | 5 +-
.../beam/sdk/io/kafka/KafkaCommitOffset.java | 1 -
.../beam/sdk/io/kafka/KafkaExactlyOnceSink.java | 67 +++++----
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 149 ++++++++++++++-------
.../org/apache/beam/sdk/io/kafka/KafkaIOUtils.java | 3 +-
.../org/apache/beam/sdk/io/kafka/KafkaRecord.java | 5 +-
.../apache/beam/sdk/io/kafka/KafkaRecordCoder.java | 10 +-
.../beam/sdk/io/kafka/KafkaSourceDescriptor.java | 47 ++++---
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 63 ++++++---
.../beam/sdk/io/kafka/KafkaUnboundedSource.java | 17 ++-
.../org/apache/beam/sdk/io/kafka/KafkaWriter.java | 67 +++++----
.../sdk/io/kafka/LocalDeserializerProvider.java | 11 +-
.../beam/sdk/io/kafka/ProducerRecordCoder.java | 22 +--
.../org/apache/beam/sdk/io/kafka/ProducerSpEL.java | 130 ++++++++++--------
.../beam/sdk/io/kafka/ReadFromKafkaDoFn.java | 56 +++++---
.../beam/sdk/io/kafka/TopicPartitionCoder.java | 1 -
.../sdk/io/kafka/WatchKafkaTopicPartitionDoFn.java | 16 +--
.../io/kafka/LocalDeserializerProviderTest.java | 14 +-
.../beam/sdk/io/kafka/ReadFromKafkaDoFnTest.java | 2 +
.../beam/sdk/io/kafka/TopicPartitionCoderTest.java | 1 -
.../io/kafka/WatchKafkaTopicPartitionDoFnTest.java | 1 -
24 files changed, 446 insertions(+), 276 deletions(-)
[beam] 01/01: Merge pull request #21783: Eliminate nullness errors in KafkaIO
Posted by ke...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
kenn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 3a6100d7af5abd3655afe9e8cd52f406044979df
Merge: b5ea07d77c0 152bcde49e4
Author: Kenneth Knowles <ke...@apache.org>
AuthorDate: Fri Jun 17 09:47:56 2022 -0700
Merge pull request #21783: Eliminate nullness errors in KafkaIO
.../src/main/resources/beam/spotbugs-filter.xml | 7 +
.../src/main/java/org/apache/beam/sdk/io/Read.java | 5 +-
...onfluentSchemaRegistryDeserializerProvider.java | 22 +--
.../beam/sdk/io/kafka/KafkaCheckpointMark.java | 5 +-
.../beam/sdk/io/kafka/KafkaCommitOffset.java | 1 -
.../beam/sdk/io/kafka/KafkaExactlyOnceSink.java | 67 +++++----
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 149 ++++++++++++++-------
.../org/apache/beam/sdk/io/kafka/KafkaIOUtils.java | 3 +-
.../org/apache/beam/sdk/io/kafka/KafkaRecord.java | 5 +-
.../apache/beam/sdk/io/kafka/KafkaRecordCoder.java | 10 +-
.../beam/sdk/io/kafka/KafkaSourceDescriptor.java | 47 ++++---
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 63 ++++++---
.../beam/sdk/io/kafka/KafkaUnboundedSource.java | 17 ++-
.../org/apache/beam/sdk/io/kafka/KafkaWriter.java | 67 +++++----
.../sdk/io/kafka/LocalDeserializerProvider.java | 11 +-
.../beam/sdk/io/kafka/ProducerRecordCoder.java | 22 +--
.../org/apache/beam/sdk/io/kafka/ProducerSpEL.java | 130 ++++++++++--------
.../beam/sdk/io/kafka/ReadFromKafkaDoFn.java | 56 +++++---
.../beam/sdk/io/kafka/TopicPartitionCoder.java | 1 -
.../sdk/io/kafka/WatchKafkaTopicPartitionDoFn.java | 16 +--
.../io/kafka/LocalDeserializerProviderTest.java | 14 +-
.../beam/sdk/io/kafka/ReadFromKafkaDoFnTest.java | 2 +
.../beam/sdk/io/kafka/TopicPartitionCoderTest.java | 1 -
.../io/kafka/WatchKafkaTopicPartitionDoFnTest.java | 1 -
24 files changed, 446 insertions(+), 276 deletions(-)