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 90c854e (commit)
to 22205ee (commit)
from 90c854e Merge pull request #15063: [BEAM-12094] Add Spark 3 to Python
(spark_runner.py)
add 6b4f097 [BEAM-12524] Use synchronized function to set instruction_id
to null.
add cae01f0 [BEAM-12524] Use synchronized function to set instruction_id
to null.
add 6d0589f [BEAM-12541] Fix partitioning requirements for filllna with
value=DataFrame or Series (#15086)
add a0f5e93 Sync Beam and Dataflow image dependencies (#15026)
add 7dfa356 More easily substituted CoGroupByKey transform. (#15029)
add c7858c8 [BEAM-12546] Swap to use ArrayBlockingQueue to improve
performance of QueueingBeamFnDataClient
add ca360f4 [BEAM-12546] Swap to use ArrayBlockingQueue to improve
performance of QueueingBeamFnDataClient
add fc4d0d3 [BEAM-10955] Sickbay very flaky Flink test
add 1dac3f7 [BEAM-10955] Sickbay very flaky Flink test #15083
add 2792270 Revert "Update test_error_message_includes_stage test"
add 22205ee Merge pull request #15092 from
apache/revert-14819-aaltay-patch-1
No new revisions were added by this update.
Summary of changes:
.../beam/runners/flink/FlinkSavepointTest.java | 2 +
.../fn/harness/control/ProcessBundleHandler.java | 2 +-
.../fn/harness/data/QueueingBeamFnDataClient.java | 7 +-
sdks/python/apache_beam/dataframe/frames.py | 37 ++++++++-
sdks/python/apache_beam/dataframe/frames_test.py | 24 ++++++
.../portability/fn_api_runner/fn_runner_test.py | 4 -
.../apache_beam/transforms/ptransform_test.py | 26 +++++++
sdks/python/apache_beam/transforms/util.py | 87 ++++++++++++----------
sdks/python/container/Dockerfile | 28 +++++--
sdks/python/container/base_image_requirements.txt | 37 ++++++---
.../container/license_scripts/dep_urls_py.yaml | 5 ++
11 files changed, 192 insertions(+), 67 deletions(-)
