This is an automated email from the ASF dual-hosted git repository.
damccorm pushed a change to branch users/damccorm/skipBatching
in repository https://gitbox.apache.org/repos/asf/beam.git
from 0d5e9967f53 Merge branch 'master' of https://github.com/apache/beam
into users/damccorm/skipBatching
add fc7b955218c Reapply "[BEAM-30531] Automatically execute unbounded
pipelines in streaming mode. (#30533)" (#30706)
add 042284afd4e Add experiment for disabling auto-streaming.
add c165f8af134 Correct release notes.
add 63ebda005d0 Merge pull request #30959 Automatically execute unbounded
pipelines in streaming mode.
add fb6bfc3ef11 Skip generating docs for yaml/integration_tests.py.
(#30986)
add a44c4f19ce3 [#30870]: support consumer polling timeout in KafkaIO
expansion service (#30915)
add e59d313c3b1 Add a link to Grafana statistics for flaky workflows
(#30934)
add 788305fdd80 Merge branch 'master' of https://github.com/apache/beam
into users/damccorm/skipBatching
No new revisions were added by this update.
Summary of changes:
.../GA-Post-Commits_status_dashboard.json | 64 ++++++++++++++--------
.../grafana/provisioning/alerting/flaky_test.yaml | 2 +-
.test-infra/tools/flaky_test_detection.py | 26 ++++++++-
CHANGES.md | 1 +
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 25 +++++++--
.../beam/sdk/io/kafka/KafkaIOExternalTest.java | 5 +-
.../io/kafka/upgrade/KafkaIOTranslationTest.java | 1 +
sdks/python/apache_beam/io/kafka.py | 11 +++-
.../runners/dataflow/dataflow_runner.py | 27 +++++++++
.../runners/dataflow/dataflow_runner_test.py | 61 +++++++++++++++++++++
sdks/python/scripts/generate_pydoc.sh | 1 +
11 files changed, 192 insertions(+), 32 deletions(-)
