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 c986168 (commit)
to e520b54 (commit)
from c986168 [BEAM-11289] [Java] Integrate Google Cloud Recommendations AI
functionality
add fcd3fcc [BEAM-12260] Java - Backport Firestore connector's ramp-up
throttling to Datastore connector (#14713)
add a4411be [BEAM-12144] Change windmill grpc streams to reevaluate
isReady and throw an exception if the stream is not finished after the deadline
has passed. Also avoid blocking on the first message as it is performed under
the StreamPool sychronized block.
add 4ed18ea Merge pull request #14714: [BEAM-12144] Change windmill grpc
streams to reevaluate isReady
add d74a9de [BEAM-9547] Add get implementation (#15030)
add 159f818 [BEAM-12514] fixed table_ref parsing when table_reference is
a ValueProvider object
add b19c53b Added changelog for BEAM-12514
add b066ecb Merge pull request #15040 from [BEAM-12514] fixes bug in
BigQueryIO - ReadFromBigQuery
add 26920e7 Support AsMultimap for legacy runners.
add dd20b4f Merge pull request #15020 Support AsMultimap for legacy
runners.
add 0cdc92b Better default windowing for zero-input PTransforms.
add f1546aa Coder cleanups.
add 8b66f37 Merge pull request #15044 Coder and Windowing cleanups.
add 975c08d [BEAM-37137] Fix xlang dependency error
add db1772e Merge pull request #15058: [BEAM-37137] Fix xlang dependency
error
add 795bb14 [BEAM-12475] Ensure the BundleProcessor.getId() is null
before calling reset.
add f795e2e [BEAM-12475] Ensure the BundleProcessor.getId() is null
before calling reset.
add fea1ea5 [BEAM-12421] Migrates ElasticsearchIOTest to use
testContainers
add 9e1a86c Adds factory method for creating consistent ES containers
add 6491421 Renames elasticsearchIOTestContainerFactory to
createTestContainer
add f746bd8 Reduces number of docs for UTests from 400 to 100
add b0b7578 [BEAM-12421] Migrates ElasticsearchIOTest to use
testContainers (#14933)
add 91e4d8c [BEAM-12475] Reject splits for previous bundles.
add c02f776 mypy
add cf8ffe6 Merge pull request #15042 from [BEAM-12475] Reject splits for
previous bundles.
add df44fb7 Update Dataflow Python container version to 20210622
add 0aed498 Update Dataflow Python container version to 20210622 #15064
add 5f993f6 [BEAM-12528] Discard failed plans.
add ceb0fe8 [BEAM-12528] Discard failed plans.
add 0f07a32 Add 2.30 release date
add 5394afa Remove placeholder entries from 2.30
add 527df11 Merge pull request #15045 from apache/aaltay-patch-1
add e520b54 [BEAM-9547] Add support for `Series.dt` methods (#14940)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 21 +-
.../worker/windmill/DirectStreamObserver.java | 62 ++++-
.../worker/windmill/GrpcWindmillServer.java | 3 +-
.../worker/windmill/StreamObserverFactory.java | 12 +-
sdks/go/pkg/beam/core/runtime/harness/harness.go | 4 +-
.../beam/fn/harness/BeamFnDataReadRunner.java | 7 +-
.../beam/fn/harness/BeamFnDataReadRunnerTest.java | 2 +
.../elasticsearch-tests-2/build.gradle | 48 ----
.../src/test/contrib/create_elk_container.sh | 24 --
.../sdk/io/elasticsearch/ElasticsearchIOIT.java | 203 ----------------
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 257 ---------------------
.../elasticsearch-tests-5/build.gradle | 8 +-
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 91 +++-----
.../elasticsearch-tests-6/build.gradle | 8 +-
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 90 +++-----
.../elasticsearch-tests-7/build.gradle | 13 +-
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 97 +++-----
.../elasticsearch-tests-common/build.gradle | 3 +
.../elasticsearch/ElasticsearchIOTestCommon.java | 32 ++-
.../io/elasticsearch/ElasticsearchIOTestUtils.java | 84 ++++++-
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 177 +++++++++++---
.../sdk/io/gcp/datastore/RampupThrottlingFn.java | 130 +++++++++++
.../beam/sdk/io/gcp/datastore/DatastoreV1Test.java | 60 ++++-
.../io/gcp/datastore/RampupThrottlingFnTest.java | 88 +++++++
sdks/python/apache_beam/coders/coders.py | 29 +--
sdks/python/apache_beam/dataframe/frames.py | 149 ++++++++++++
sdks/python/apache_beam/dataframe/frames_test.py | 84 +++++++
.../apache_beam/dataframe/pandas_doctests_test.py | 57 ++---
.../io/flink/flink_streaming_impulse_source.py | 2 +-
sdks/python/apache_beam/io/gcp/bigquery.py | 2 +-
sdks/python/apache_beam/pvalue.py | 11 +-
.../apache_beam/runners/dataflow/internal/names.py | 4 +-
.../apache_beam/runners/direct/direct_runner.py | 2 +-
.../apache_beam/runners/worker/bundle_processor.py | 13 +-
sdks/python/apache_beam/transforms/core.py | 7 -
sdks/python/apache_beam/transforms/ptransform.py | 9 +-
sdks/python/container/base_image_requirements.txt | 1 +
37 files changed, 1014 insertions(+), 880 deletions(-)
delete mode 100644
sdks/java/io/elasticsearch-tests/elasticsearch-tests-2/build.gradle
delete mode 100755
sdks/java/io/elasticsearch-tests/elasticsearch-tests-2/src/test/contrib/create_elk_container.sh
delete mode 100644
sdks/java/io/elasticsearch-tests/elasticsearch-tests-2/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOIT.java
delete mode 100644
sdks/java/io/elasticsearch-tests/elasticsearch-tests-2/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/RampupThrottlingFn.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/datastore/RampupThrottlingFnTest.java
