This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from 6c15b0f (commit)
to c53118c (commit)
from 6c15b0f Merge pull request #15031: [BEAM-12507][BEAM-12508] Fix
release content blockers
add 9af555d [BEAM-12490] Fixed test_harness_monitoring_infos_and_metadata
precommit error (#15033)
add e6e9b83 Prefetch subsequent pages over the FnAPI. (#14803)
add 8255137 [BEAM-10708] Save and load coders correctly
add e95b18a Fixed lint
add 19aaad2 Fixed the cache_manager write implementation.
add e7bb8b9 Fixed lint
add 6781ce8 Fixed lint
add 4e0fbad Merge pull request #15023 from KevinGG/sql
add a286049 [BEAM-12389] fix xlang validate runner test flakiness
add 8ab0d34 Merge pull request #15025 from ihji/BEAM-12389
add b8ac766 Fix job configuration additional_bq_parameters reference link
add 67518ce Merge pull request #15038: Fix job configuration
additional_bq_parameters reference link
add a929659 Merge pull request #14745 from [BEAM-11359] Removed temporary
dataset from BigQuery after pipeline completion
add c36422d Merge pull request #14690 from [BEAM-12445] Moving streaming
inserts with new client
add 50fef9d [BEAM-12074] Make sure all GroupBy operations have docstrings
(#14963)
add f377fe0 [BEAM-12495] Fail early when attempting to group multiple
columns with dropna=False (#15019)
add c53118c Minor: Fix WontImplementMethod typo (#15018)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 17 +++--
runners/flink/job-server/flink_job_server.gradle | 4 +-
runners/spark/job-server/spark_job_server.gradle | 4 +-
.../fn/harness/state/StateFetchingIterators.java | 33 ++++++---
.../harness/state/StateFetchingIteratorsTest.java | 9 ++-
sdks/python/apache_beam/dataframe/expressions.py | 18 ++---
sdks/python/apache_beam/dataframe/frame_base.py | 4 +-
sdks/python/apache_beam/dataframe/frames.py | 67 +++++++++++++-----
sdks/python/apache_beam/dataframe/frames_test.py | 33 ++++++++-
sdks/python/apache_beam/io/gcp/bigquery.py | 11 +--
.../apache_beam/io/gcp/bigquery_read_internal.py | 10 ++-
sdks/python/apache_beam/io/gcp/bigquery_test.py | 52 +++++---------
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 80 +++++++++++-----------
.../apache_beam/io/gcp/bigquery_tools_test.py | 29 +++-----
sdks/python/apache_beam/io/gcp/gcsio.py | 4 +-
sdks/python/apache_beam/io/gcp/gcsio_test.py | 10 ++-
.../runners/interactive/background_caching_job.py | 6 +-
.../runners/interactive/cache_manager.py | 33 ++++++---
.../runners/interactive/cache_manager_test.py | 37 ++++------
.../runners/interactive/caching/streaming_cache.py | 47 +++++++++----
.../interactive/caching/streaming_cache_test.py | 19 +++++
.../interactive/pipeline_instrument_test.py | 6 +-
.../container/license_scripts/dep_urls_py.yaml | 2 +
sdks/python/setup.py | 4 +-
sdks/python/test-suites/direct/xlang/build.gradle | 2 +-
25 files changed, 332 insertions(+), 209 deletions(-)
