This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from 2781342 (commit)
to a724602 (commit)
from 2781342 [BEAM-11461] update tox and simplify tox.ini (#13692)
add 35a49d1 Kafka To Pub/Sub Template Blogpost (#13365)
add 8d6fd6a [BEAM-10961] Enabled strict dependency on Core Java runner
(#13654)
add c27b8d6 [BEAM-10961] Enabled strict dependency on Twister2 (#13669)
add b131cc88 [BEAM-10961] Enabled strict dependencies on
sdks-fn-execution and sdks-harness (#13687)
add 6628a27 Enabled strict dependency on core-construction runnber module
add 51a495f set enableStrictDependencies: true
add eed16a5 Merge pull request #13650 from
sonam-vend/runner-core-construction
add c5e6cc5 Enabled strict dependency on Extensions Java runner
add a9c6cb6 set enableStrictDependencies: true
add 0bfdf6c Merge pull request #13657 from
sonam-vend/runner-extension-java
add d1c8c24 [BEAM-10961] Enabled strict dependencies on java-job-service
(#13662)
add 7e87324 [BEAM-10961] Enabled Strict dependency on Fn-execution Runner
(#13661)
add a724602 [BEAM-11659]: Add DlqProvider, a way of handling failures in
a generic way. (#13773)
No new revisions were added by this update.
Summary of changes:
runners/core-construction-java/build.gradle | 5 +-
runners/core-java/build.gradle | 8 +-
runners/extensions-java/metrics/build.gradle | 4 +-
runners/java-fn-execution/build.gradle | 7 +-
runners/java-job-service/build.gradle | 10 ++-
runners/twister2/build.gradle | 17 ++++-
...{InvalidLocationException.java => Failure.java} | 30 +++++---
.../org/apache/beam/sdk/schemas/io/GenericDlq.java | 66 ++++++++++++++++
...chemaException.java => GenericDlqProvider.java} | 21 +++--
.../apache/beam/sdk/schemas/io/GenericDlqTest.java | 61 +++++++++++++++
.../beam/sdk/schemas/io/StoringDlqProvider.java | 72 +++++++++++++++++
sdks/java/fn-execution/build.gradle | 3 +-
sdks/java/harness/build.gradle | 5 +-
.../sdk/io/gcp/bigquery/BigQueryDlqProvider.java | 85 +++++++++++++++++++++
.../beam/sdk/io/gcp/pubsub/PubsubDlqProvider.java | 66 ++++++++++++++++
.../beam/sdk/io/gcp/pubsublite/DlqProvider.java | 77 +++++++++++++++++++
website/www/site/content/en/blog/beam-2.27.0.md | 1 +
.../content/en/blog/kafka-to-pubsub-example.md | 89 ++++++++++++++++++++++
website/www/site/data/authors.yml | 13 ++++
19 files changed, 598 insertions(+), 42 deletions(-)
copy
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/{InvalidLocationException.java
=> Failure.java} (57%)
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/GenericDlq.java
copy
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/{InvalidSchemaException.java
=> GenericDlqProvider.java} (68%)
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/io/GenericDlqTest.java
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/io/StoringDlqProvider.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryDlqProvider.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubDlqProvider.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/DlqProvider.java
create mode 100644 website/www/site/content/en/blog/kafka-to-pubsub-example.md
