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 6d0e00ea617 added defaultQueryTimeout for jdbc io (#35376)
add b97ee3110d0 [yaml]: Phase2 High Usage Yaml examples (#35279)
add cb5eef5b6f1 ✨[Feature]: Add pip-based install support for JupyterLab
side panel extension (#35399)
add 0595584d986 Skip sliding window tests on samza and spark runner test
suites (#35430)
add ac350626fa4 Pin torch dependencies to tested versions (#35431)
add 6ac5009dbfd Fix post commit xlang jdbcio test failure (#35428)
add 944aaa0e1f9 Disable dependency logging in local envs (#35404)
add ffd89458a85 add filter to watermark query (#35042)
add 4a7a9a39d31 Fix data race ExecutionStateSampler.java:491 in
ExecutionStateImpl.reset() (#35135)
No new revisions were added by this update.
Summary of changes:
.github/trigger_files/beam_PostCommit_Python.json | 2 +-
...am_PostCommit_Python_ValidatesRunner_Samza.json | 3 +-
...am_PostCommit_Python_ValidatesRunner_Spark.json | 3 +-
.../beam_PostCommit_Python_Xlang_Gcp_Direct.json | 2 +-
CHANGES.md | 1 +
.../fn/harness/control/ExecutionStateSampler.java | 11 +-
.../changestreams/cache/AsyncWatermarkCache.java | 21 +++-
.../changestreams/cache/NoOpWatermarkCache.java | 2 +-
.../changestreams/dao/PartitionMetadataDao.java | 31 ++++--
.../SpannerChangeStreamErrorTest.java | 12 ++-
.../changestreams/it/SpannerChangeStreamIT.java | 3 +
...StreamOrderedByTimestampAndTransactionIdIT.java | 3 +
...nnerChangeStreamOrderedWithinKeyGloballyIT.java | 3 +
.../it/SpannerChangeStreamOrderedWithinKeyIT.java | 3 +
.../it/SpannerChangeStreamPostgresIT.java | 3 +
...SpannerChangeStreamTransactionBoundariesIT.java | 3 +
.../it/SpannerChangeStreamsSchemaTransformIT.java | 3 +
.../io/external/xlang_jdbcio_it_test.py | 10 ++
.../python/apache_beam/options/pipeline_options.py | 9 ++
.../apache-beam-jupyterlab-sidepanel/.gitignore | 6 ++
.../apache-beam-jupyterlab-sidepanel/README.md | 100 ++++++++++++++++-
.../apache_beam_jupyterlab_sidepanel/__init__.py | 7 +-
.../apache_beam_jupyterlab_sidepanel/_version.py | 6 +-
.../apache-beam-jupyterlab-sidepanel/package.json | 2 +-
.../pyproject.toml | 67 ++++++++++++
.../runners/portability/samza_runner_test.py | 3 +
.../runners/portability/sdk_container_builder.py | 3 +-
.../runners/portability/spark_runner_test.py | 3 +
sdks/python/apache_beam/transforms/environments.py | 8 +-
.../yaml/examples/testing/examples_test.py | 119 +++++++++++++++++++--
.../yaml/examples/testing/input_data.py | 71 +++++++++++-
.../transforms/blueprint/jdbc_to_bigquery.yaml | 57 ++++++++++
.../blueprint/pubsub_subscription_to_bigquery.yaml | 61 +++++++++++
.../blueprint/pubsub_topic_to_bigquery.yaml | 61 +++++++++++
.../transforms/blueprint/spanner_to_avro.yaml | 45 ++++++++
sdks/python/setup.py | 2 +-
36 files changed, 699 insertions(+), 50 deletions(-)
create mode 100644
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/.gitignore
copy .test-infra/kubernetes/hadoop/LargeITCluster/teardown.sh =>
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/apache_beam_jupyterlab_sidepanel/__init__.py
(84%)
mode change 100755 => 100644
copy .test-infra/metrics/sync/jenkins/requirements.txt =>
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/apache_beam_jupyterlab_sidepanel/_version.py
(95%)
create mode 100644
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/pyproject.toml
create mode 100644
sdks/python/apache_beam/yaml/examples/transforms/blueprint/jdbc_to_bigquery.yaml
create mode 100644
sdks/python/apache_beam/yaml/examples/transforms/blueprint/pubsub_subscription_to_bigquery.yaml
create mode 100644
sdks/python/apache_beam/yaml/examples/transforms/blueprint/pubsub_topic_to_bigquery.yaml
create mode 100644
sdks/python/apache_beam/yaml/examples/transforms/blueprint/spanner_to_avro.yaml
