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 bd3649e (commit)
to ff70e74 (commit)
from bd3649e Merge pull request #15007 from [BEAM-12428] Implement
TokenCredentialSerializer in AzureModule.java
add 95fa963 [BEAM-12802] Refactor DataStreamsDecoder so that it becomes
aware of the ByteString iterator.
add a328d0e [BEAM-12802] Refactor DataStreamsDecoder so that it becomes
aware of the ByteString iterator and in the future will be able to answer
whether there is data available or do we need to fetch more data.
add b22523a add python spark example in documentation (#15426)
add 3314fe9 [BEAM-11994] Instantiate a new ServiceCallMetric before each
request to avoid concurrent modification exception
add 75ea7ea Merge pull request #15420 from [BEAM-11994] Instantiate a new
ServiceCallMetric before each request to avoid concurrent modification exception
add c73ec81 Remove duplicate 2.33.0 section
add dd7945f Merge pull request #15423 from angoenka/fix-release-notes
add 43f8961 [BEAM-12776] Change closing to happen in background in
parallel for multiple windows
add 3337301 Merge pull request #15354: [BEAM-12776] Change closing to
happen in background in parallel for multiple windows
add 5fb6011 Allow `google-auth < 3`
add 1227339 Allow google-auth < 3 #15346
add 16224d3 [BEAM-12767] Improve PipelineOption parsing UX
add 0592083 [BEAM-12767] Improve PipelineOption parsing UX
add d09fceb Fix typo in BigQuery documentation
add a36e332 Merge pull request #15413: Fix typo in BigQuery documentation
add 99b5bfa sync nltk, orjson for Python image
add ff70e74 Merge pull request #15326 from emilymye/importsync
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 30 +--
.../java/org/apache/beam/sdk/io/WriteFiles.java | 54 ++++-
.../apache/beam/sdk/options/PipelineOptions.java | 14 ++
.../beam/sdk/options/PipelineOptionsFactory.java | 259 ++++++++++++++++++++-
.../beam/sdk/options/ProxyInvocationHandler.java | 90 +++++--
.../sdk/options/PipelineOptionsFactoryTest.java | 159 +++++++++++++
.../sdk/options/ProxyInvocationHandlerTest.java | 59 +++++
.../org/apache/beam/sdk/fn/stream/DataStreams.java | 160 +++++++------
.../apache/beam/sdk/fn/stream/DataStreamsTest.java | 48 ++--
.../beam/fn/harness/state/FnApiStateAccessor.java | 4 +-
.../beam/fn/harness/state/StateBackedIterable.java | 4 +-
.../fn/harness/state/StateFetchingIterators.java | 8 +-
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 3 +-
sdks/python/apache_beam/io/gcp/bigquery.py | 2 +-
sdks/python/container/Dockerfile | 2 +
sdks/python/container/base_image_requirements.txt | 3 +-
sdks/python/setup.py | 5 +-
.../site/content/en/documentation/runners/spark.md | 4 +
18 files changed, 712 insertions(+), 196 deletions(-)
