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 1fbc55e (commit)
to 1a260cd (commit)
from 1fbc55e Merge pull request #12182 [BEAM-4605] Remove portable runner
GBK hack.
add fe258ed [BEAM-10414] Fix FlinkStreamingImpulseSource translation
add 85e8ddd Merge pull request #12189: [BEAM-10414] Fix
FlinkStreamingImpulseSource translation
add af1ce25 [BEAM-10392] Make sure that messages that are unroutable are
returned to the sender and redelivered.
add b675aca Update
sdks/java/io/rabbitmq/src/test/java/org/apache/beam/sdk/io/rabbitmq/RabbitMqIOTest.java
add 0b34546 Merge pull request #12184: [BEAM-10392] Fix flakiness of
RabbitMqIOTest by handling unroutable messages
add 48dfb7b [BEAM-10371] Run dependency check script with Python 3
(#12132)
add d74f110 [BEAM-10419] Skip FhirIORead integration test due to flakiness
add cdc44d9 Merge pull request #12191 from y1chi/BEAM-10419
add 7554f13 [BEAM-10165] Cache and return error messages on pipeline
failure. (#11912)
add 3688d47 Test group by and aggregation on DATE and TIME type
add f65a187 Merge pull request #12120: [BEAM-10224] Test group by and
aggregation on DATE and TIME type
add a90c51a Merge pull request #12143 from [BEAM-10291] Adding full
thread dump upon lull detection for Dataflow…
add 207a882 [BEAM-10243] Fix and test FieldValueBuilder::withFieldValues.
add d250a1d Merge pull request #12200 from ibzib/BEAM-10243
add bc6790f Declare Python 3.8 support in setup.py
add d01e941 Adds a note about Python 3.8 support in CHANGES.md
add 2dddc0c [BEAM-8494] Declare Python 3.8 support in setup.py.
add 53bbb2b get default GCP region option (Go)
add cbab5d2 Remove cmd.String() call to support Go 1.12.
add 7e4cb7a [BEAM-8472] get default GCP region option (Go)
add fb6fc78 Add failing value provider option test
add 5ee1b71 fix pipeline options in PortableRunner
add d2d4ecb Make sdk_worker_main_test assertions more specific
add 1a260cd [BEAM-10007] Handle ValueProvider pipeline options in
PortableRunner (#11744)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 5 +-
.../dataflow/worker/DataflowOperationContext.java | 94 +++++++++++++++--
.../worker/DataflowOperationContextTest.java | 116 +++++++++++++++++----
sdks/go/pkg/beam/options/gcpopts/options.go | 29 ++++++
sdks/go/pkg/beam/runners/dataflow/dataflow.go | 10 +-
.../main/java/org/apache/beam/sdk/values/Row.java | 4 +-
.../java/org/apache/beam/sdk/values/RowTest.java | 13 +++
.../sql/impl/rel/BeamAggregationRel.java | 10 +-
.../beam/sdk/extensions/sql/zetasql/TestInput.java | 14 +--
.../sql/zetasql/ZetaSQLDialectSpecTest.java | 74 +++++++++++++
.../beam/sdk/io/gcp/healthcare/FhirIOReadIT.java | 2 +
.../beam/sdk/io/rabbitmq/RabbitMqIOTest.java | 115 +++++++++++---------
sdks/python/apache_beam/__init__.py | 2 +-
.../io/flink/flink_streaming_impulse_source.py | 6 +-
.../flink/flink_streaming_impulse_source_test.py} | 24 ++---
.../portability/fn_api_runner/fn_runner_test.py | 16 +++
.../runners/portability/local_job_service.py | 56 ++++++++--
.../runners/portability/local_job_service_test.py | 36 +++++++
.../runners/portability/portable_runner.py | 14 ++-
.../runners/worker/sdk_worker_main_test.py | 55 ++++++----
sdks/python/build.gradle | 9 +-
sdks/python/scripts/run_dependency_check.sh | 13 +--
sdks/python/setup.py | 3 +-
sdks/python/test-suites/tox/pycommon/build.gradle | 2 +
sdks/python/tox.ini | 10 ++
25 files changed, 562 insertions(+), 170 deletions(-)
copy sdks/python/apache_beam/{coders/fast_coders_test.py =>
io/flink/flink_streaming_impulse_source_test.py} (64%)
