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 840462b109a Fix PreCommit Java IO Direct Job (#36696)
add f774df0e6af Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#36706)
add 093084a015a Install yaml extra when running yaml tests (#36707)
add 40e2b0d01f2 Only log Kafka commit failures as warning every 10m and if
failing for > 10m. (#36685)
add 3a1ae18a8d4 Split some dependencies out of main beam package into
existing extras (#36697)
add 1f63118d993 Fix warning message (#36703)
add 89947fded65 fix jsonToRowTest race condition (#36616)
add 6327aab91c5 Multimap streaming (#36714)
No new revisions were added by this update.
Summary of changes:
.../beam_PostCommit_Yaml_Xlang_Direct.yml | 2 +-
.../workflows/beam_PreCommit_Yaml_Xlang_Direct.yml | 4 +-
.../beam/runners/dataflow/DataflowRunner.java | 34 +--------
.../beam/runners/dataflow/DataflowRunnerTest.java | 80 +++++++++++++++++++++-
sdks/go.mod | 2 +-
sdks/go.sum | 4 +-
.../org/apache/beam/sdk/util/RowJsonUtils.java | 31 +++++----
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 22 +++++-
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 2 +-
.../runners/interactive/display/pipeline_graph.py | 7 +-
sdks/python/apache_beam/transforms/core.py | 21 +++---
sdks/python/apache_beam/transforms/core_test.py | 16 ++---
sdks/python/apache_beam/yaml/json_utils.py | 7 +-
sdks/python/apache_beam/yaml/main_test.py | 6 ++
sdks/python/apache_beam/yaml/yaml_io_test.py | 6 ++
sdks/python/apache_beam/yaml/yaml_mapping_test.py | 6 ++
.../python/apache_beam/yaml/yaml_transform_test.py | 6 ++
.../apache_beam/yaml/yaml_transform_unit_test.py | 1 +
sdks/python/setup.py | 10 +--
sdks/python/tox.ini | 2 +-
20 files changed, 184 insertions(+), 85 deletions(-)
