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 d20d0b01c3c Upgrading spring-expression to latest patch version
(#25348)
add 2a350761d09 Better batching for higher fixed costs.
add d6d88808aa4 Add an option to get the old behavior.
add 37112d65578 lint
add 46a5e77232d Merge pull request #25351 Better batching for higher fixed
costs.
add bf5114bb2fc [BEAM-12164] Enforced only positive state transitions from
CREATED -> SCHEDULED -> RUNNING -> FINISHED for the change stream metadata
table. (#25311)
add a9e80d2981c Added Role-based access control integration tests for
Spanner Change Streams (#25246)
add 88da381cc33 Fail the pipeline when a mismatched Python or Beam version
is detected. (#25313)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 6 +-
.../action/DetectNewPartitionsAction.java | 2 +-
.../action/QueryChangeStreamAction.java | 2 +-
.../changestreams/dao/PartitionMetadataDao.java | 85 +++++++++++++++-
.../dao/PartitionMetadataDaoTest.java | 108 ++++++++++++++++++---
.../it/ChangeStreamTestPipelineOptions.java | 8 +-
.../changestreams/it/IntegrationTestEnv.java | 62 ++++++++++--
.../changestreams/it/SpannerChangeStreamIT.java | 40 +++++++-
sdks/python/apache_beam/pipeline_test.py | 16 +++
.../apache_beam/runners/worker/bundle_processor.py | 23 +++++
sdks/python/apache_beam/transforms/environments.py | 9 +-
sdks/python/apache_beam/transforms/util.py | 40 ++++++--
sdks/python/apache_beam/transforms/util_test.py | 18 +++-
13 files changed, 372 insertions(+), 47 deletions(-)
