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%)