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 2024/09/20 03:50:05 UTC
(beam) branch nightly-refs/heads/master updated (aeead3f7cd3 -> 7581eb1667b)
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 aeead3f7cd3 Disable a permared suite. (#32493)
add 83411302794 add test to verify kafka sdf commit expansion (#32438)
add bb96ac0456c Publish Java Expansion Service SNAPSHOT containers (#32491)
add ec307a52496 Emit warning when Mqtt waiting for connection for extended period of time (#32500)
add 75a463790d7 Support Managed Iceberg streaming writes (#32451)
add 7581eb1667b Add runners/prism/java to java PreCommit (#32507)
No new revisions were added by this update.
Summary of changes:
.../IO_Iceberg_Integration_Tests.json | 2 +-
.../workflows/beam_Publish_Beam_SDK_Snapshots.yml | 1 +
build.gradle.kts | 1 +
.../beam/runners/prism/PrismLocatorTest.java | 2 +
sdks/java/io/expansion-service/build.gradle | 3 +-
sdks/java/io/iceberg/hive/exec/build.gradle | 15 ++--
.../beam/sdk/io/iceberg/AppendFilesToTables.java | 19 ++++-
.../org/apache/beam/sdk/io/iceberg/IcebergIO.java | 51 +++++++++++++-
.../IcebergWriteSchemaTransformProvider.java | 80 +++++++++++++++++++---
.../apache/beam/sdk/io/iceberg/RecordWriter.java | 7 +-
.../beam/sdk/io/iceberg/RecordWriterManager.java | 29 ++++----
.../beam/sdk/io/iceberg/WriteToDestinations.java | 50 +++++++++++++-
.../apache/beam/sdk/io/iceberg/IcebergIOIT.java | 74 ++++++++++++++++++++
.../beam/sdk/io/iceberg/IcebergIOWriteTest.java | 62 +++++++++++++++++
.../IcebergWriteSchemaTransformProviderTest.java | 5 +-
.../beam/sdk/io/kafka/ReadFromKafkaDoFnTest.java | 60 ++++++++++++++++
.../java/org/apache/beam/sdk/io/mqtt/MqttIO.java | 24 +++++--
.../org/apache/beam/sdk/io/mqtt/MqttIOTest.java | 7 +-
18 files changed, 442 insertions(+), 50 deletions(-)