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(-)
