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 5df59a943d1 Add flag to control automatic exception sampling in Java
(disabled) (#28403)
add 19fec19bf93 Update website to have Beam College banners (#28459)
add a9a0f8dbfca Add official govulncheck action to Go Tests workflow
(#28456)
add f09955e47d7 Bump google.golang.org/grpc from 1.58.0 to 1.58.1 in /sdks
(#28464)
add 108680aadbd gcsio.py use RuntimeError with exc chaining instead of
overwriting previous exception (#28470)
add 8415534040b added beam_PostCommit_PortableJar jobs to GitHub Actions
(#28447)
add 52eed458d2a Migrate
"beam_PostCommit_Python_ValidatesContainer_Dataflow" Jenkins jobs to GitHub
Actions (#28448)
add da6f1348ef0 beam_PostCommit_Python_Xlang (#28466)
add cfc96940d5a Github Workflow Replacement for Jenkins Jobs,
beam_PostCommit_XVR_* (#28432)
add 2dd8d28d424 Migrate "beam_PostCommit_Java_Examples_*" Jenkins jobs to
GitHub Actions (#28409)
add a0f14a84c3f Prism docker env (#28444)
add 13b12dab004 Add mechanism to override bigtable client for testing
add 23b583bd721 Merge pull request #28374: Add mechanism to override
bigtable client for testing
add 67a9cf37861 Allow dropLataData in GBK for SamzaRunner (#28461)
add d1fffb60de6 added beam_PostCommit_Python_MongoDBIO_IT job to GitHub
Actions (#28472)
add d32ddc6f19d added beam_PostCommit_Java_Hadoop_Versions job to GitHub
Actions (#28473)
add 38720a39d91 Github Workflow Replacement for Jenkins Job,
beam_PostCommit_Website_Test (#28368)
add 1f980eaa894 Remove implicitly defined IOs. (#28479)
add 841d7cd3a71 Update dataflow container version (#28484)
add 6870283a56c [BEAM-28399] Ensure dataflow experiments are always set
when dataflow runner is used.
add 52abb1452e6 Merge pull request #28485 [BEAM-28399] Ensure dataflow
experiments are always set when dataflowflow runner is used.
No new revisions were added by this update.
Summary of changes:
.github/workflows/README.md | 25 ++-
.../beam_PostCommit_Java_Examples_Dataflow_ARM.yml | 2 +-
...eam_PostCommit_Java_Examples_Dataflow_Java.yml} | 27 ++-
...ml => beam_PostCommit_Java_Examples_Direct.yml} | 25 ++-
...yml => beam_PostCommit_Java_Examples_Flink.yml} | 33 ++--
...yml => beam_PostCommit_Java_Examples_Spark.yml} | 25 ++-
...ml => beam_PostCommit_Java_Hadoop_Versions.yml} | 63 +++----
.../beam_PostCommit_PortableJar_Flink.yml | 88 +++++++++
.../beam_PostCommit_PortableJar_Spark.yml | 88 +++++++++
.../beam_PostCommit_Python_MongoDBIO_IT.yml | 95 ++++++++++
...stCommit_Python_ValidatesContainer_Dataflow.yml | 105 +++++++++++
..._Python_ValidatesContainer_Dataflow_With_RC.yml | 106 +++++++++++
.../beam_PostCommit_Python_Xlang_Gcp_Dataflow.yml | 88 +++++++++
.../beam_PostCommit_Python_Xlang_Gcp_Direct.yml | 87 +++++++++
.../beam_PostCommit_Python_Xlang_IO_Dataflow.yml | 90 ++++++++++
.github/workflows/beam_PostCommit_Website_Test.yml | 76 ++++++++
.github/workflows/beam_PostCommit_XVR_Direct.yml | 104 +++++++++++
.github/workflows/beam_PostCommit_XVR_Flink.yml | 105 +++++++++++
...eam_PostCommit_XVR_JavaUsingPython_Dataflow.yml | 92 ++++++++++
..._PostCommit_XVR_PythonUsingJavaSQL_Dataflow.yml | 89 +++++++++
...eam_PostCommit_XVR_PythonUsingJava_Dataflow.yml | 92 ++++++++++
.github/workflows/beam_PostCommit_XVR_Samza.yml | 104 +++++++++++
.github/workflows/beam_PostCommit_XVR_Spark3.yml | 104 +++++++++++
.github/workflows/go_tests.yml | 6 +
CHANGES.md | 3 +-
.../beam/runners/samza/SamzaPipelineOptions.java | 6 +
.../beam/runners/samza/runtime/GroupByKeyOp.java | 12 +-
.../runners/samza/runtime/GroupByKeyOpTest.java | 123 +++++++++++++
sdks/go.mod | 2 +-
sdks/go.sum | 4 +-
sdks/go/pkg/beam/core/runtime/metricsx/metricsx.go | 3 +-
.../beam/runners/prism/internal/environments.go | 199 +++++++++++++++++++++
sdks/go/pkg/beam/runners/prism/internal/execute.go | 90 +++-------
.../runners/prism/internal/jobservices/artifact.go | 48 ++++-
.../beam/runners/prism/internal/jobservices/job.go | 10 ++
.../prism/internal/jobservices/management.go | 2 +
.../runners/prism/internal/jobservices/server.go | 5 +
.../beam/runners/prism/internal/worker/worker.go | 17 +-
.../pkg/beam/runners/universal/runnerlib/stage.go | 2 +-
.../beam/sdk/io/gcp/bigtable/BigtableConfig.java | 12 ++
.../beam/sdk/io/gcp/bigtable/BigtableIO.java | 19 ++
.../dao/BigtableChangeStreamAccessor.java | 7 +
.../changestreams/dao/BigtableClientOverride.java | 58 ++++++
sdks/python/apache_beam/io/gcp/gcsio.py | 3 +-
.../runners/dataflow/dataflow_runner.py | 2 +
.../apache_beam/runners/dataflow/internal/names.py | 2 +-
sdks/python/apache_beam/yaml/yaml_io.py | 16 +-
website/www/site/layouts/partials/header.html | 6 +-
.../static/images/college_2023_banner_desktop.png | Bin 0 -> 159958 bytes
.../static/images/college_2023_banner_mobile.png | Bin 0 -> 594273 bytes
50 files changed, 2172 insertions(+), 198 deletions(-)
rename .github/workflows/{beam_PostCommit_Java_Examples_Dataflow_Java11.yml =>
beam_PostCommit_Java_Examples_Dataflow_Java.yml} (79%)
copy .github/workflows/{beam_PostCommit_Java_Examples_Dataflow_Java17.yml =>
beam_PostCommit_Java_Examples_Direct.yml} (81%)
copy .github/workflows/{beam_PostCommit_Java_Examples_Dataflow_Java17.yml =>
beam_PostCommit_Java_Examples_Flink.yml} (79%)
copy .github/workflows/{beam_PostCommit_Java_Examples_Dataflow_Java17.yml =>
beam_PostCommit_Java_Examples_Spark.yml} (81%)
rename .github/workflows/{beam_PostCommit_Java_Examples_Dataflow_Java17.yml =>
beam_PostCommit_Java_Hadoop_Versions.yml} (57%)
create mode 100644 .github/workflows/beam_PostCommit_PortableJar_Flink.yml
create mode 100644 .github/workflows/beam_PostCommit_PortableJar_Spark.yml
create mode 100644 .github/workflows/beam_PostCommit_Python_MongoDBIO_IT.yml
create mode 100644
.github/workflows/beam_PostCommit_Python_ValidatesContainer_Dataflow.yml
create mode 100644
.github/workflows/beam_PostCommit_Python_ValidatesContainer_Dataflow_With_RC.yml
create mode 100644
.github/workflows/beam_PostCommit_Python_Xlang_Gcp_Dataflow.yml
create mode 100644
.github/workflows/beam_PostCommit_Python_Xlang_Gcp_Direct.yml
create mode 100644
.github/workflows/beam_PostCommit_Python_Xlang_IO_Dataflow.yml
create mode 100644 .github/workflows/beam_PostCommit_Website_Test.yml
create mode 100644 .github/workflows/beam_PostCommit_XVR_Direct.yml
create mode 100644 .github/workflows/beam_PostCommit_XVR_Flink.yml
create mode 100644
.github/workflows/beam_PostCommit_XVR_JavaUsingPython_Dataflow.yml
create mode 100644
.github/workflows/beam_PostCommit_XVR_PythonUsingJavaSQL_Dataflow.yml
create mode 100644
.github/workflows/beam_PostCommit_XVR_PythonUsingJava_Dataflow.yml
create mode 100644 .github/workflows/beam_PostCommit_XVR_Samza.yml
create mode 100644 .github/workflows/beam_PostCommit_XVR_Spark3.yml
create mode 100644
runners/samza/src/test/java/org/apache/beam/runners/samza/runtime/GroupByKeyOpTest.java
create mode 100644 sdks/go/pkg/beam/runners/prism/internal/environments.go
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/dao/BigtableClientOverride.java
create mode 100644
website/www/site/static/images/college_2023_banner_desktop.png
create mode 100644
website/www/site/static/images/college_2023_banner_mobile.png
