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 d13e86b3f50 Merge pull request #17581: [BEAM-14436] Adds code
reviewers for GCP I/O connectors and KafkaIO to Beam OWNERS files
add f1234007ad8 Changing elegibility to AllNodeElegibility
add c9883b25d2d [BEAM-13666] Stuck inventory jobs should be cancelled and
rescheduled for next run (#17582)
add 71baac91e88 Add extra details to PubSub matcher errors
add 0ea809590ee [BEAM-14439] [BEAM-12673] Add extra details to PubSub
matcher errors #17586
add 4f519b1ecc8 Merge pull request #17559 from [BEAM-14423] Add exception
injection tests for BigtableIO read in BigtableIOTest
add 28e4e2f273d [BEAM-11104] Allow self-checkpointing SDFs to return
without finishing their restriction (#17558)
add 3689dc5fbeb Merge pull request #17544 from [BEAM-14415] Exception
handling tests for BQIO streaming inserts in Python
add 6a28d0656d9 Merge pull request #17565 from [BEAM-14413] add Kafka
exception test cases
add 9807938d347 Merge pull request #17555 from [BEAM-14417] Adding
exception handling tests for JdbcIO.Write
add 1af17bdbea9 [BEAM-14433] Improve Go split error message. (#17575)
add 178441dcf0a [BEAM-14429] Force java load test on dataflow runner v2
forceNumInitialBundles to 1 (#17576)
add b212f1c1965 Merge pull request #17577 from [BEAM-14435] Adding
exception handling tests for SpannerIO write transform
add 36d40f40694 [BEAM-14347] Add generic registration functions for iters
and emitters (#17574)
add 85d9824f108 [BEAM-14169] Add Credentials rotation cron job for
clusters (#17383)
add a5fbc8ed163 [BEAM-14347] Add generic registration for accumulators
(#17579)
No new revisions were added by this update.
Summary of changes:
.../job_IODatastoresCredentialsRotation.groovy | 56 ++
.test-infra/jenkins/job_Inventory.groovy | 2 +-
.../job_LoadTests_CoGBK_Dataflow_V2_Java11.groovy | 10 +
.../job_LoadTests_CoGBK_Dataflow_V2_Java17.groovy | 10 +
.../job_LoadTests_GBK_Dataflow_V2_Java11.groovy | 19 +-
.../job_LoadTests_GBK_Dataflow_V2_Java17.groovy | 19 +-
.../job_LoadTests_ParDo_Dataflow_V2_Java11.groovy | 14 +-
.../job_LoadTests_ParDo_Dataflow_V2_Java17.groovy | 14 +-
.../jenkins/job_MetricsCredentialsRotation.groovy | 56 ++
sdks/go/pkg/beam/core/runtime/exec/datasource.go | 8 +-
sdks/go/pkg/beam/core/runtime/exec/pardo.go | 12 +-
sdks/go/pkg/beam/core/runtime/exec/pardo_test.go | 248 ++++++++
sdks/go/pkg/beam/registration/emitter.go | 164 ++++++
.../beam/registration/example_registration_test.go | 43 +-
sdks/go/pkg/beam/registration/iter.go | 129 ++++
sdks/go/pkg/beam/registration/registration.go | 655 ++++++++++++++++++++-
sdks/go/pkg/beam/registration/registration.tmpl | 310 +++++++++-
sdks/go/pkg/beam/registration/registration_test.go | 460 +++++++++++++++
.../beam/sdk/io/gcp/bigtable/BigtableIOTest.java | 202 ++++++-
.../SpannerIOWriteExceptionHandlingTest.java | 225 +++++++
.../sdk/io/gcp/spanner/SpannerIOWriteTest.java | 32 +-
.../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 6 +-
.../JdbcIOExceptionHandlingParameterizedTest.java | 146 +++++
.../org/apache/beam/sdk/io/jdbc/JdbcIOTest.java | 46 +-
.../beam/sdk/io/kafka/KafkaCommitOffsetTest.java | 46 +-
.../org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 67 +++
.../org/apache/beam/sdk/io/kafka/KafkaMocks.java | 113 ++++
.../beam/sdk/io/kafka/ReadFromKafkaDoFnTest.java | 65 ++
sdks/python/apache_beam/io/gcp/bigquery_test.py | 263 +++++++++
.../apache_beam/io/gcp/tests/pubsub_matcher.py | 32 +-
sdks/python/apache_beam/utils/retry.py | 22 +
31 files changed, 3416 insertions(+), 78 deletions(-)
create mode 100644
.test-infra/jenkins/job_IODatastoresCredentialsRotation.groovy
create mode 100644 .test-infra/jenkins/job_MetricsCredentialsRotation.groovy
create mode 100644 sdks/go/pkg/beam/registration/emitter.go
create mode 100644 sdks/go/pkg/beam/registration/iter.go
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIOWriteExceptionHandlingTest.java
create mode 100644
sdks/java/io/jdbc/src/test/java/org/apache/beam/sdk/io/jdbc/JdbcIOExceptionHandlingParameterizedTest.java
create mode 100644
sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaMocks.java
