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 2023/11/12 03:50:36 UTC
(beam) branch nightly-refs/heads/master updated (d49c2681f7a -> 2ad45911313)
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 d49c2681f7a Merge pull request #29375 Add some missing finally blocks on context managers.
add 281a4fa6db4 Fix MongoDBIO ignore SSL KeyStore not initialized (#29393)
add 1e1c2a319f6 Invoke pyarrow_hotfix to alleviate concerns due to CVE-2023-47248. (#29396)
add 39986e60ea3 Update image tag pattern for RCs in release docs (#29406)
add 2ad45911313 [YAML] - Kafka Read and Write proto (#29368)
No new revisions were added by this update.
Summary of changes:
contributor-docs/release-guide.md | 6 +-
sdks/java/extensions/protobuf/build.gradle | 2 +
.../sdk/extensions/protobuf/ProtoByteUtils.java | 233 +++++++++++++++++++++
.../extensions/protobuf/ProtoByteUtilsTest.java | 98 +++++++++
.../protobuf/src/test/resources/README.md | 6 +
.../proto_byte/file_descriptor/proto_byte_utils.pb | 13 ++
.../resources/proto_byte/proto_byte_utils.proto | 23 +-
sdks/java/io/kafka/README.md | 10 +
sdks/java/io/kafka/build.gradle | 1 +
.../KafkaReadSchemaTransformConfiguration.java | 18 +-
.../io/kafka/KafkaReadSchemaTransformProvider.java | 34 ++-
.../kafka/KafkaWriteSchemaTransformProvider.java | 87 ++++----
.../KafkaReadSchemaTransformProviderTest.java | 58 ++++-
.../KafkaWriteSchemaTransformProviderTest.java | 77 +++++--
.../proto_byte/file_descriptor/proto_byte_utils.pb | 13 ++
.../resources/proto_byte/proto_byte_utils.proto | 23 +-
.../org/apache/beam/sdk/io/mongodb/SSLUtils.java | 2 +-
.../apache/beam/sdk/io/mongodb/SSLUtilsTest.java} | 16 +-
sdks/python/apache_beam/__init__.py | 8 +
sdks/python/apache_beam/yaml/standard_io.yaml | 4 +
.../container/py310/base_image_requirements.txt | 1 +
.../container/py311/base_image_requirements.txt | 1 +
.../container/py38/base_image_requirements.txt | 1 +
.../container/py39/base_image_requirements.txt | 1 +
sdks/python/setup.py | 12 +-
.../site/content/en/blog/validate-beam-release.md | 6 +-
26 files changed, 655 insertions(+), 99 deletions(-)
create mode 100644 sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoByteUtils.java
create mode 100644 sdks/java/extensions/protobuf/src/test/java/org/apache/beam/sdk/extensions/protobuf/ProtoByteUtilsTest.java
create mode 100644 sdks/java/extensions/protobuf/src/test/resources/proto_byte/file_descriptor/proto_byte_utils.pb
copy playground/frontend/lib/modules/examples/models/popover_state.dart => sdks/java/extensions/protobuf/src/test/resources/proto_byte/proto_byte_utils.proto (76%)
create mode 100644 sdks/java/io/kafka/src/test/resources/proto_byte/file_descriptor/proto_byte_utils.pb
copy playground/frontend/lib/modules/examples/models/popover_state.dart => sdks/java/io/kafka/src/test/resources/proto_byte/proto_byte_utils.proto (76%)
copy sdks/java/io/mongodb/src/{main/java/org/apache/beam/sdk/io/mongodb/package-info.java => test/java/org/apache/beam/sdk/io/mongodb/SSLUtilsTest.java} (74%)