This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from cccb6494667 Fix Community Metrics Prober job (#39290)
add 09af958190b Fix BeamRowWrapperTest microsecond precision flake (#39287)
add 23e23981b63 Fix GCP IO tests on Java 21 (#39295)
add ad6762a3bee --add-opens JVM flags (#39302)
add f20fca2d9e4 Add JVM --add-opens flags for Flink PVR on Java 21 (#39303)
add 5a3bbbaba0f rename scanner (#39304)
add ab498be6ef3 Use sbt 1.x
add 1e05fcd9815 Merge pull request #39291 from apache/fix-scio
add 42daed36b39 Bump jackson version. (#39281)
add 20ed72c83e3 [IcebergIO] Support TableIdentifiers with special
characters (#38876)
add 5af82d31aed Bump golang.org/x/crypto from 0.45.0 to 0.52.0 in
/.test-infra/mock-apis (#39314)
No new revisions were added by this update.
Summary of changes:
.../IO_Iceberg_Integration_Tests.json | 2 +-
.../beam_PostCommit_Java_PVR_Flink_Streaming.json | 2 +-
.test-infra/mock-apis/go.mod | 10 ++--
.test-infra/mock-apis/go.sum | 20 +++----
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
playground/backend/containers/scio/Dockerfile | 22 ++++++--
runners/flink/job-server/flink_job_server.gradle | 25 ++++++++-
.../container/license_scripts/dep_urls_java.yaml | 2 +-
sdks/java/io/google-cloud-platform/build.gradle | 5 ++
.../gcp/bigquery/BeamRowToStorageApiProtoTest.java | 11 +++-
.../org/apache/beam/sdk/io/iceberg/AddFiles.java | 8 +--
.../beam/sdk/io/iceberg/AppendFilesToTables.java | 5 +-
.../iceberg/AssignDestinationsAndPartitions.java | 3 +-
.../beam/sdk/io/iceberg/FileWriteResult.java | 4 +-
.../beam/sdk/io/iceberg/IcebergCatalogConfig.java | 6 +-
.../IcebergCdcReadSchemaTransformProvider.java | 3 +-
.../IcebergReadSchemaTransformProvider.java | 3 +-
.../beam/sdk/io/iceberg/IcebergScanConfig.java | 6 +-
.../apache/beam/sdk/io/iceberg/IcebergUtils.java | 54 ++++++++++++++++++
.../beam/sdk/io/iceberg/IncrementalScanSource.java | 4 +-
.../io/iceberg/OneTableDynamicDestinations.java | 6 +-
.../io/iceberg/PortableIcebergDestinations.java | 3 +-
.../apache/beam/sdk/io/iceberg/SnapshotInfo.java | 3 +-
.../org/apache/beam/sdk/io/iceberg/TableCache.java | 6 +-
.../beam/sdk/io/iceberg/cdc/ChangelogScanner.java | 4 +-
....java => BeamBaseIncrementalChangelogScan.java} | 10 ++--
.../beam/sdk/io/iceberg/BeamRowWrapperTest.java | 9 ++-
.../beam/sdk/io/iceberg/IcebergIOReadTest.java | 3 +-
.../beam/sdk/io/iceberg/IcebergIOWriteTest.java | 3 +-
.../beam/sdk/io/iceberg/IcebergUtilsTest.java | 64 ++++++++++++++++++++++
sdks/java/testing/load-tests/build.gradle | 14 +++++
31 files changed, 248 insertions(+), 74 deletions(-)
rename
sdks/java/io/iceberg/src/main/java/org/apache/iceberg/{BaseIncrementalChangelogScan.java
=> BeamBaseIncrementalChangelogScan.java} (99%)
