You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2022/03/04 04:15:33 UTC
[beam] branch nightly-refs/heads/master updated (74ab15c -> 2aa4da0)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 74ab15c [BEAM-13892] Improve coverage of avroio package (#16990)
add 06e7c20 [adhoc] Prepare aws2 ClientConfiguration for json serialization and cleanup AWS Module (#16894)
add 14d02ee Merge pull request #16879 from [BEAM-12164] Add javadocs to SpannerConfig
add 6438626 [Cleanup] Update pre-v2 go package references (#17002)
add 0671d6d [BEAM-13885] Add unit tests to window package (#16971)
add d6b7144 Merge pull request #16891 from [BEAM-13872] [Playground] Increase test coverage for the code_processing package
add f296c09 Merge pull request #16912 from [BEAM-13878] [Playground] Increase test coverage for the fs_tool package
add 322d7df Merge pull request #16946 from [BEAM-13873] [Playground] Increase test coverage for the environment package
add 43804b5 [BEAM-13999] playground - support vertical orientation for graph
add fa5fffd Merge pull request #16963 from [BEAM-13999] [Playground] support vertical orientation for graph
add d466379 [BEAM-13951] Update mass_comment.py list of Run commands (#16889)
add 117123c [BEAM-10652] Allow Clustering without Partition in BigQuery (#16578)
add 2aa4da0 [BEAM-13857] Add K:V flags for expansion service jars and addresses to Go ITs. (#16908)
No new revisions were added by this update.
Summary of changes:
.../code_processing/code_processing_test.go | 705 ++++++++++++++++++---
.../internal/environment/application_test.go | 56 +-
.../backend/internal/environment/beam_test.go | 41 +-
.../environment/environment_service_test.go | 181 +++++-
playground/backend/internal/fs_tool/fs_test.go | 63 +-
playground/backend/internal/fs_tool/go_fs_test.go | 2 +-
.../backend/internal/fs_tool/java_fs_test.go | 17 +-
.../backend/internal/fs_tool/path_checker_test.go | 93 +++
.../backend/internal/fs_tool/python_fs_test.go | 2 +-
.../internal/setup_tools/builder/setup_builder.go | 2 +-
.../modules/graph/graph_builder/canvas_drawer.dart | 11 +-
.../modules/graph/graph_builder/graph_builder.dart | 25 +-
.../graph/graph_builder/painters/edge_painter.dart | 118 +++-
.../graph_builder/painters/graph_painter.dart | 18 +-
.../lib/modules/output/components/graph.dart | 15 +-
.../lib/modules/output/components/output_area.dart | 22 +-
release/src/main/scripts/mass_comment.py | 118 +++-
sdks/go/pkg/beam/core/graph/window/fn_test.go | 92 +++
sdks/go/pkg/beam/core/graph/window/windows.go | 7 +
sdks/go/pkg/beam/core/graph/window/windows_test.go | 154 +++++
sdks/go/pkg/beam/core/runtime/harness/datamgr.go | 2 +-
.../pkg/beam/core/runtime/harness/datamgr_test.go | 2 +-
sdks/go/pkg/beam/core/runtime/harness/statemgr.go | 2 +-
sdks/go/pkg/beam/util/gcsx/gcs.go | 2 +-
sdks/go/test/integration/expansions.go | 119 ++++
sdks/go/test/integration/expansions_test.go | 179 ++++++
sdks/go/test/integration/flags.go | 86 ++-
sdks/go/test/integration/internal/jars/jars.go | 64 ++
.../go/test/integration/internal/jars/proc.go | 14 +-
.../cluster_unix.go => internal/jars/proc_unix.go} | 24 +-
.../test/integration/internal/jars/run_nonunix.go | 54 ++
sdks/go/test/integration/internal/jars/run_unix.go | 65 ++
.../integration/internal/ports/ports.go} | 18 +-
sdks/java/io/amazon-web-services2/build.gradle | 1 +
.../sdk/io/aws2/common/ClientConfiguration.java | 95 +--
.../io/aws2/common/HttpClientConfiguration.java | 23 +-
.../sdk/io/aws2/common/RetryConfiguration.java | 43 +-
.../apache/beam/sdk/io/aws2/options/AwsModule.java | 80 +--
.../apache/beam/sdk/io/aws2/s3/SSECustomerKey.java | 6 +
.../io/aws2/common/ClientConfigurationTest.java | 31 +-
.../aws2/common/HttpClientConfigurationTest.java | 49 ++
.../sdk/io/aws2/common/RetryConfigurationTest.java | 22 +
.../beam/sdk/io/aws2/options/AwsModuleTest.java | 29 -
.../beam/sdk/io/aws2/s3/SSECustomerKeyTest.java | 17 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 11 +-
.../beam/sdk/io/gcp/bigquery/WriteTables.java | 7 +-
.../beam/sdk/io/gcp/spanner/SpannerConfig.java | 25 +
...ClusteringIT.java => BigQueryClusteringIT.java} | 86 +--
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 9 -
.../content/en/documentation/programming-guide.md | 8 +-
.../documentation/resources/learning-resources.md | 2 +-
.../www/site/content/en/documentation/sdks/go.md | 2 +-
.../site/content/en/get-started/quickstart-go.md | 8 +-
.../site/content/en/get-started/try-apache-beam.md | 10 +-
.../content/en/get-started/wordcount-example.md | 14 +-
55 files changed, 2450 insertions(+), 501 deletions(-)
create mode 100644 playground/backend/internal/fs_tool/path_checker_test.go
create mode 100644 sdks/go/pkg/beam/core/graph/window/fn_test.go
create mode 100644 sdks/go/pkg/beam/core/graph/window/windows_test.go
create mode 100644 sdks/go/test/integration/expansions.go
create mode 100644 sdks/go/test/integration/expansions_test.go
create mode 100644 sdks/go/test/integration/internal/jars/jars.go
copy learning/katas/go/introduction/hello_beam/hello_beam/pkg/task/task.go => sdks/go/test/integration/internal/jars/proc.go (83%)
copy sdks/go/test/integration/{io/xlang/kafka/cluster_unix.go => internal/jars/proc_unix.go} (66%)
create mode 100644 sdks/go/test/integration/internal/jars/run_nonunix.go
create mode 100644 sdks/go/test/integration/internal/jars/run_unix.go
copy sdks/go/{pkg/beam/core/util/protox/protox.go => test/integration/internal/ports/ports.go} (69%)
create mode 100644 sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/common/HttpClientConfigurationTest.java
copy sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/{BigQueryTimePartitioningClusteringIT.java => BigQueryClusteringIT.java} (69%)