[beam] branch nightly-refs/heads/master updated (df67c817184 -> a1674241c68)

[gi...@apache.org]

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 df67c817184 [BEAM-11104] Add self-checkpointing integration test (#17590)
     add a1810537c45 [BEAM-5492] Python Dataflow integration tests should export the pipeline console output to Jenkins Test Result section (#17530)
     add 0f38c82007b [BEAM-14396] Bump httplib2 upper bound. (#17602)
     add 43cc865c9e7 [BEAM-11104] Add self-checkpointing to CHANGES.md (#17612)
     add f30e4e57ecf [BEAM-14081] [CdapIO] Add context classes for CDAP plugins (#17104)
     add fbc495c66e7 [BEAM-12526] Add Dependabot (#17563)
     add 86b68aa57cb [BEAM-14096] bump junit-quickcheck to 1.0
     add d6df30601dd Merge pull request #17519: [BEAM-14096] bump junit-quickcheck to 1.0
     add f81119a2271 Remove python 3.6 postcommit from mass_comment.py (#17630)
     add 59cdb5869e7 [BEAM-14347] Add some benchmarks for generic registration (#17613)
     add 6ee09b66901 Correctly route go dependency changes to go label (#17632)
     add a1674241c68 [BEAM-13695] Add jamm jvm options to Java 11 (#17178)

No new revisions were added by this update.

Summary of changes:
 .github/autolabeler.yml                            |   2 +-
 .../docker/pkglist => .github/dependabot.yml       |  50 ++---
 CHANGES.md                                         |   2 +-
 .../org/apache/beam/gradle/BeamModulePlugin.groovy |   5 +-
 release/src/main/scripts/mass_comment.py           |   1 -
 sdks/go/pkg/beam/register/register.go              | 240 ++++++++++-----------
 sdks/go/pkg/beam/register/register.tmpl            |   4 +-
 sdks/go/pkg/beam/register/register_test.go         | 149 +++++++++++++
 sdks/java/container/boot.go                        |   3 +-
 sdks/java/container/boot_test.go                   |  74 +++++++
 sdks/java/container/common.gradle                  |   2 +-
 .../container/{java17 => java11}/option-jamm.json  |   0
 .../container/test/disabled/option-disabled.json   |   6 +
 sdks/java/container/test/empty/README              |   1 +
 sdks/java/container/test/priority/option-high.json |  16 ++
 sdks/java/container/test/priority/option-low.json  |  16 ++
 sdks/java/io/cdap/build.gradle                     |  11 +-
 .../beam/sdk/io/cdap/context/BatchContextImpl.java | 232 ++++++++++++++++++++
 .../sdk/io/cdap/context/BatchSinkContextImpl.java} |  20 +-
 .../io/cdap/context/BatchSourceContextImpl.java    |  29 ++-
 .../io/cdap/context/FailureCollectorWrapper.java   |  55 +++++
 .../cdap/context/StreamingSourceContextImpl.java   |  30 ++-
 .../beam/sdk/io/cdap/context}/package-info.java    |   5 +-
 .../sdk/io/cdap/context/BatchContextImplTest.java} |  45 ++--
 .../cdap/context/FailureCollectorWrapperTest.java  |  93 ++++++++
 .../runners/dataflow/dataflow_runner.py            |   9 +-
 .../runners/dataflow/test_dataflow_runner.py       |   8 +-
 sdks/python/setup.py                               | 230 ++++++++++----------
 28 files changed, 986 insertions(+), 352 deletions(-)
 copy dev-support/docker/pkglist => .github/dependabot.yml (66%)
 create mode 100644 sdks/java/container/boot_test.go
 copy sdks/java/container/{java17 => java11}/option-jamm.json (100%)
 create mode 100644 sdks/java/container/test/disabled/option-disabled.json
 create mode 100644 sdks/java/container/test/empty/README
 create mode 100644 sdks/java/container/test/priority/option-high.json
 create mode 100644 sdks/java/container/test/priority/option-low.json
 create mode 100644 sdks/java/io/cdap/src/main/java/org/apache/beam/sdk/io/cdap/context/BatchContextImpl.java
 copy sdks/java/{fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/AdvancingPhaser.java => io/cdap/src/main/java/org/apache/beam/sdk/io/cdap/context/BatchSinkContextImpl.java} (67%)
 copy runners/twister2/src/main/java/org/apache/beam/runners/twister2/translation/wrappers/Twister2EmptySource.java => sdks/java/io/cdap/src/main/java/org/apache/beam/sdk/io/cdap/context/BatchSourceContextImpl.java (60%)
 create mode 100644 sdks/java/io/cdap/src/main/java/org/apache/beam/sdk/io/cdap/context/FailureCollectorWrapper.java
 copy runners/twister2/src/main/java/org/apache/beam/runners/twister2/translation/wrappers/Twister2EmptySource.java => sdks/java/io/cdap/src/main/java/org/apache/beam/sdk/io/cdap/context/StreamingSourceContextImpl.java (55%)
 copy sdks/java/io/{synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/delay => cdap/src/main/java/org/apache/beam/sdk/io/cdap/context}/package-info.java (92%)
 copy sdks/java/{core/src/test/java/org/apache/beam/sdk/options/ExperimentalOptionsTest.java => io/cdap/src/test/java/org/apache/beam/sdk/io/cdap/context/BatchContextImplTest.java} (51%)
 create mode 100644 sdks/java/io/cdap/src/test/java/org/apache/beam/sdk/io/cdap/context/FailureCollectorWrapperTest.java