beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From github-...@apache.org
Subject [beam] tag nightly-master updated (2781342 -> a724602)
Date Thu, 21 Jan 2021 04:10:59 GMT
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


Mime
View raw message