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 (61a884e -> b8e390a)
Date Fri, 23 Jul 2021 03:23:04 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 61a884e  (commit)
      to b8e390a  (commit)
    from 61a884e  Merge pull request #15182 from pcoet/website-docs
     add 09d4fab  Default to Runner v2 for Python Streaming jobs. (#15140)
     add 31c2b76  Moving to 2.33.0-SNAPSHOT on master branch.
     add e8f9ad9  [BEAM-12548] Fix malformed comment for EqualsFloat (#15200)
     add bbe7b64  [BEAM-4152] Implement session window merging in the Go direct runner (#15196)
     add f88ed4e  [BEAM-12643] Resolved the concurrent writes issue for parallel tests (#15199)
     add 63257ed  [BEAM-10212] Add caching state client wrapper (#15170)
     add 2d7c4a8  [BEAM-12625] Annotate testTwoTimersSettingEachOtherWithCreateAsInputUnbounded.
     add b8e390a  Merge pull request #15205 from ibzib/BEAM-12625

No new revisions were added by this update.

Summary of changes:
 .../org/apache/beam/gradle/BeamModulePlugin.groovy |   2 +-
 gradle.properties                                  |   4 +-
 sdks/go/pkg/beam/core/core.go                      |   2 +-
 sdks/go/pkg/beam/core/util/hooks/hooks.go          | 124 ++++++--
 sdks/go/pkg/beam/core/util/hooks/hooks_test.go     |  60 +++-
 sdks/go/pkg/beam/runners/direct/gbk.go             | 109 ++++++-
 sdks/go/pkg/beam/runners/direct/gbk_test.go        |  88 ++++++
 sdks/go/pkg/beam/testing/passert/floats.go         |   2 +-
 sdks/go/test/integration/integration.go            |   2 -
 .../org/apache/beam/sdk/transforms/ParDoTest.java  |   7 +-
 .../fn/harness/state/CachingBeamFnStateClient.java | 178 +++++++++++
 .../state/CachingBeamFnStateClientTest.java        | 335 +++++++++++++++++++++
 .../fn/harness/state/FakeBeamFnStateClient.java    |   4 +
 .../runners/dataflow/dataflow_runner.py            |   8 +-
 .../runners/dataflow/dataflow_runner_test.py       |  11 +-
 sdks/python/apache_beam/version.py                 |   2 +-
 16 files changed, 872 insertions(+), 66 deletions(-)
 create mode 100644 sdks/go/pkg/beam/runners/direct/gbk_test.go
 create mode 100644 sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/CachingBeamFnStateClient.java
 create mode 100644 sdks/java/harness/src/test/java/org/apache/beam/fn/harness/state/CachingBeamFnStateClientTest.java

Mime
View raw message