You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2023/02/19 04:29:59 UTC

[beam] branch nightly-refs/heads/master updated (40838f76447 -> 977e53104f4)

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 40838f76447 Support Avro GenericRecord as a valid format for StorageWrite API on BigQueryIO (#24274)
     add ee9244d6261 complete examples links fixed
     add 20c8d3a2ba1 Merge pull request #25527: [CdapIO][SparkReceiverIO] Complete examples links in READMEs and CdapIO website page fixed
     add 6de67443528 Stop use of self hosted runners for some workflows. (#25542)
     add 29856ae9471 Run prbot updates on hosted runners (#25544)
     add f358fcdc8c8 prism-fixstatic (#25546)
     add 86920261ca7 Update Go SDK minimum Go version to 1.19 (#25545)
     add 2b6291250f9 Replace more uses of `ClassLoadingStrategy.Default.INJECTION` (#23210)
     add 907533220b8 Use WindowedValue.withValue on hot paths #21250 (#25519)
     add de7eb2d83b0 Stop paying the iterator object creation tax in MultiplexingMetricTrackingFnDataReceiver (#25540)
     add 977e53104f4 [prism] add windowing strategy (#25518)

No new revisions were added by this update.

Summary of changes:
 .../actions/setup-self-hosted-action/action.yml    |   8 +-
 .github/workflows/build_playground_frontend.yml    |   2 +-
 .github/workflows/git_tag_released_version.yml     |   2 +-
 .github/workflows/go_tests.yml                     |   4 +-
 .github/workflows/issue-tagger.yml                 |   2 +-
 .github/workflows/label_prs.yml                    |   2 +-
 .github/workflows/playground_deploy_backend.yml    |   2 +-
 .github/workflows/pr-bot-new-prs.yml               |   2 +-
 .github/workflows/pr-bot-pr-updates.yml            |   2 +-
 .github/workflows/pr-bot-prs-needing-attention.yml |   2 +-
 .github/workflows/publish_github_release_notes.yml |   4 +-
 .github/workflows/python_tests.yml                 |   2 +-
 .github/workflows/reportGenerator.yml              |   2 +-
 .github/workflows/self-assign.yml                  |   2 +-
 .github/workflows/stale.yml                        |   2 +-
 .github/workflows/triaged-on-assign.yml            |   2 +-
 CHANGES.md                                         |   1 +
 .../org/apache/beam/gradle/BeamModulePlugin.groovy |   2 +-
 dev-support/docker/Dockerfile                      |   2 +-
 sdks/go.mod                                        |   2 +-
 .../beam/runners/prism/internal/engine/strategy.go |  39 +++-
 .../prism/internal/engine/strategy_test.go}        |  42 ++--
 .../prism/internal/jobservices/metrics_test.go     |   3 +-
 .../apache/beam/sdk/coders/RowCoderGenerator.java  |   7 +-
 .../beam/sdk/schemas/utils/AvroByteBuddyUtils.java |   5 +-
 .../beam/sdk/schemas/utils/ByteBuddyUtils.java     |   4 +-
 .../beam/sdk/schemas/utils/JavaBeanUtils.java      |  11 +-
 .../apache/beam/sdk/schemas/utils/POJOUtils.java   |  10 +-
 .../sdk/schemas/utils/SelectByteBuddyHelpers.java  |   7 +-
 .../reflect/ByteBuddyOnTimerInvokerFactory.java    |  10 +-
 .../org/apache/beam/sdk/util/ByteBuddyUtils.java   |  57 +++++
 .../apache/beam/fn/harness/FnApiDoFnRunner.java    | 257 +++++++++++++++++----
 .../harness/data/PCollectionConsumerRegistry.java  |  10 +-
 sdks/java/io/cdap/README.md                        |   2 +-
 sdks/java/io/sparkreceiver/2/README.md             |   2 +-
 .../content/en/documentation/io/built-in/cdap.md   |   2 +-
 .../content/en/documentation/programming-guide.md  |   2 +-
 .../site/content/en/get-started/quickstart-go.md   |   2 +-
 38 files changed, 374 insertions(+), 147 deletions(-)
 copy learning/katas/go/windowing/adding_timestamp/pardo/pkg/task/task.go => sdks/go/pkg/beam/runners/prism/internal/engine/strategy.go (59%)
 copy sdks/go/pkg/beam/{core/graph/coder/time_test.go => runners/prism/internal/engine/strategy_test.go} (52%)
 create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/util/ByteBuddyUtils.java