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 2021/08/11 03:09:42 UTC
[beam] tag nightly-master updated (2fd9875 -> b9b4c6e)

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 2fd9875  (commit)
      to b9b4c6e  (commit)
    from 2fd9875  Merge pull request #15269 from ihji/BEAM-12716
     add d980232  Fix typo
     add 09548a9  Merge pull request #15302 from chamikaramj/fix_doc_typo
     add b5820a2  [BEAM-12403][BEAM-12348] Add User State Support for Portable SamzaRunner (#15280)
     add e6f80a1  Update beam dataflow python container versions.
     add ce406c6  Merge pull request #15305 from y1chi/update_py_container
     add f4f5489  Update Google Cloud Healthcare API version from v1beta1 to GA (v1-rev20210603)
     add 927aae5  Merge pull request #15268 from Update Google Cloud Healthcare API version from v1beta1 to GA
     add 9e8fae7  Add support for python sdk container to turn on google cloud profiler via dataflow service options
     add 3d5b221  format file
     add b9b4c6e  Merge pull request #15296 from andyxiexu/python-sdk

No new revisions were added by this update.

Summary of changes:
 CHANGES.md                                         |   1 +
 .../org/apache/beam/gradle/BeamModulePlugin.groovy |   2 +-
 runners/samza/job-server/build.gradle              |   2 -
 .../apache/beam/runners/samza/runtime/DoFnOp.java  |  41 +++---
 .../beam/runners/samza/runtime/GroupByKeyOp.java   |   4 +-
 .../runners/samza/runtime/SamzaDoFnRunners.java    |  44 ++++++-
 .../samza/runtime/SamzaStateRequestHandlers.java   | 146 ++++++++++++++++++---
 .../samza/runtime/SamzaStoreStateInternals.java    |  58 ++++++--
 .../SplittableParDoProcessKeyedElementsOp.java     |   4 +-
 .../translation/ParDoBoundMultiTranslator.java     |  50 ++++++-
 .../beam/runners/samza/util/StateUtils.java}       |  27 ++--
 .../runtime/SamzaTimerInternalsFactoryTest.java    |   6 +-
 .../apache/beam/sdk/io/gcp/healthcare/FhirIO.java  |  24 ++--
 .../apache/beam/sdk/io/gcp/healthcare/HL7v2IO.java |  27 ++--
 .../beam/sdk/io/gcp/healthcare/HL7v2Message.java   |   4 +-
 .../sdk/io/gcp/healthcare/HL7v2MessageCoder.java   |   2 +-
 .../sdk/io/gcp/healthcare/HealthcareApiClient.java |  20 +--
 .../io/gcp/healthcare/HttpHealthcareApiClient.java |  61 +++++----
 .../beam/sdk/io/gcp/healthcare/FhirIOLROIT.java    |   2 +-
 .../io/gcp/healthcare/HL7V2MessagePagesTest.java   |   4 +-
 .../beam/sdk/io/gcp/healthcare/HL7v2IOTest.java    |   2 +-
 .../sdk/io/gcp/healthcare/HL7v2IOTestUtil.java     |   2 +-
 .../beam/sdk/io/gcp/healthcare/HL7v2IOWriteIT.java |   2 +-
 .../apache_beam/runners/dataflow/internal/names.py |   4 +-
 .../runners/portability/samza_runner_test.py       |  20 +--
 .../apache_beam/runners/worker/sdk_worker_main.py  |   9 +-
 .../www/site/content/en/documentation/glossary.md  |   4 +-
 .../content/en/documentation/programming-guide.md  |   2 +-
 28 files changed, 388 insertions(+), 186 deletions(-)
 copy runners/{java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ExecutableStageContext.java => samza/src/main/java/org/apache/beam/runners/samza/util/StateUtils.java} (55%)