You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ib...@apache.org on 2020/04/07 00:12:10 UTC
[beam] branch master updated (db3d832 -> 64e69d6)
This is an automated email from the ASF dual-hosted git repository.
ibzib pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from db3d832 Merge pull request #11269 from ibzib/beam-9199
new 254cc95 [BEAM-9199] Require --region option for Dataflow in Java SDK.
new ea67a3d Add --region to Java GCP tests.
new 4a1ccbc Fix DataflowRunnerTest.
new 77a1565 Fix more Java unit tests missing --region.
new 5faeab3 Add --region to DF streaming example tests.
new 28b117b Add --region to Dataflow runner webpage.
new e3f1ed0 Add --region to more Java tests and examples.
new 71a1fdf Remove unrecognized --region option from non-DF tests.
new 64e69d6 Merge pull request #11281 from ibzib/beam-9199-java
The 26365 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../jenkins/NexmarkBigqueryProperties.groovy | 1 +
release/src/main/groovy/TestScripts.groovy | 10 +++++
.../main/groovy/quickstart-java-dataflow.groovy | 1 +
runners/google-cloud-dataflow-java/build.gradle | 11 +++++
.../examples-streaming/build.gradle | 3 ++
.../examples/build.gradle | 2 +
.../beam/runners/dataflow/DataflowRunner.java | 4 ++
.../dataflow/options/DataflowPipelineOptions.java | 8 +---
.../beam/runners/dataflow/DataflowRunnerTest.java | 51 ++++++++--------------
.../runners/dataflow/TestDataflowRunnerTest.java | 1 +
.../options/DataflowPipelineOptionsTest.java | 4 +-
.../transforms/DataflowGroupByKeyTest.java | 1 +
.../dataflow/transforms/DataflowViewTest.java | 2 +
.../WorkerCustomSourcesSplitOnlySourceTest.java | 13 +++++-
.../dataflow/worker/WorkerCustomSourcesTest.java | 33 +++++++-------
sdks/java/extensions/sql/build.gradle | 2 +
sdks/java/extensions/sql/datacatalog/build.gradle | 2 +
sdks/java/extensions/zetasketch/build.gradle | 2 +
website/src/documentation/runners/dataflow.md | 7 +++
website/src/documentation/sdks/nexmark.md | 2 +
website/src/get-started/quickstart-java.md | 2 +
website/src/get-started/wordcount-example.md | 6 +++
22 files changed, 107 insertions(+), 61 deletions(-)