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 89ae2763844 Fix: Dedup input list of Topics/TopicPartitions in KafkaIO
(#35758)
add 689b86410d0 fix windows slashes for dask (#30528) (#35781)
add 185dee0c994 Add a pipeline option for setting prism log level. (#35778)
add 5593f405cbe Fix race conditions in apache.beam.sdks.schemas (#35752)
add ed992508c1d Fix a split bundle bug when using timers in stateful dofn
(#35770)
add a247319eb61 Fix options.go flag comments (#35785)
add 720f9617be0 Metastore example (#35722)
add ac2706a291b Fix timestamp issue in a yaml pipeline that calls SQL
transform (#35789)
No new revisions were added by this update.
Summary of changes:
examples/java/build.gradle | 1 +
.../cookbook/IcebergBatchWriteExample.java | 208 +++++++++++++++++++++
sdks/go/pkg/beam/options/jobopts/options.go | 6 +-
.../prism/internal/engine/elementmanager.go | 34 +++-
sdks/go/pkg/beam/runners/prism/internal/stage.go | 2 +-
.../beam/runners/prism/internal/worker/bundle.go | 4 +-
.../apache/beam/sdk/schemas/CachingFactory.java | 16 +-
.../beam/sdk/schemas/FromRowUsingCreator.java | 2 +-
.../python/apache_beam/options/pipeline_options.py | 9 +-
.../runners/portability/prism_runner.py | 4 +
sdks/python/apache_beam/typehints/schemas.py | 12 +-
sdks/python/apache_beam/yaml/tests/sql.yaml | 18 ++
sdks/python/scripts/run_pytest.sh | 6 +-
13 files changed, 298 insertions(+), 24 deletions(-)
create mode 100644
examples/java/src/main/java/org/apache/beam/examples/cookbook/IcebergBatchWriteExample.java
