You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2022/12/14 04:54:19 UTC
[beam] branch nightly-refs/heads/master updated (6bbc396342a -> 77af3237521)

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

github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from 6bbc396342a Merge pull request #24583: Suppress checker framework memory constraint warning
     add 4766c201c8b Eliminate rawtypes from KafkaIO
     add 80bdbb02fdc Merge pull request #24631: Eliminate rawtypes from KafkaIO
     add b896cd5ab6d Improve Integer conversion in BigQueryIO's Storage Write API method. (#24366)
     add 4c3750dcd0c Remove 'Hidden' attribute from serviceAccount PipelineOption (#24642)
     add 0ad7dc02eef disable daemon
     add 772c7ce95a8 Merge pull request #24641 from kileys/daemon
     add eec1c773a23 Allow avro block size to be configurable in AvroIO.write (#24454)
     add b479e03b87b Eliminate rawtypes from GCP IO
     add 77af3237521 Merge pull request #24624: Eliminate rawtypes from GCP IO

No new revisions were added by this update.

Summary of changes:
 gradle.properties                                  |  1 +
 .../dataflow/options/DataflowPipelineOptions.java  |  2 -
 .../main/java/org/apache/beam/sdk/io/AvroIO.java   | 28 +++++-
 .../main/java/org/apache/beam/sdk/io/AvroSink.java | 20 +++--
 .../io/gcp/bigquery/TableRowToStorageApiProto.java | 46 +++++++++-
 .../io/gcp/bigquery/UpdateSchemaDestination.java   | 10 ++-
 .../apache/beam/sdk/io/gcp/healthcare/DicomIO.java |  2 +-
 .../io/gcp/pubsub/PubSubPayloadTranslation.java    |  3 +-
 .../dofn/DetectNewPartitionsDoFn.java              |  1 -
 .../bigquery/TableRowToStorageApiProtoTest.java    | 99 ++++++++++++++++++++++
 .../beam/sdk/io/gcp/healthcare/DicomIOReadIT.java  |  2 +-
 .../changestreams/util/TestTransactionAnswer.java  |  7 +-
 ...onfluentSchemaRegistryDeserializerProvider.java |  8 +-
 .../beam/sdk/io/kafka/KafkaCommitOffset.java       |  5 +-
 .../beam/sdk/io/kafka/KafkaExactlyOnceSink.java    |  3 +-
 .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 95 +++++++++++----------
 .../apache/beam/sdk/io/kafka/KafkaRecordCoder.java | 13 ++-
 .../beam/sdk/io/kafka/KafkaUnboundedReader.java    | 13 ++-
 .../beam/sdk/io/kafka/ProducerRecordCoder.java     | 13 ++-
 .../beam/sdk/io/kafka/ReadFromKafkaDoFn.java       | 25 +++---
 ...uentSchemaRegistryDeserializerProviderTest.java | 13 ++-
 .../beam/sdk/io/kafka/KafkaIOExternalTest.java     | 12 +--
 ...KafkaIOReadImplementationCompatibilityTest.java |  3 +-
 .../apache/beam/sdk/io/kafka/KafkaIOUtilsTest.java |  7 +-
 .../beam/sdk/io/kafka/KafkaRecordCoderTest.java    |  7 +-
 .../beam/sdk/io/kafka/ProducerRecordCoderTest.java | 19 ++---
 .../beam/sdk/io/kafka/ReadFromKafkaDoFnTest.java   | 22 ++---
 27 files changed, 305 insertions(+), 174 deletions(-)