You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tv...@apache.org on 2021/11/19 00:53:56 UTC
[beam] branch release-2.35.0 updated (611a8e6 -> a54d71c)
This is an automated email from the ASF dual-hosted git repository.
tvalentyn pushed a change to branch release-2.35.0
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 611a8e6 Set Dataflow container to release version.
add 53226fe Fix race condition in Pub/Sub Lite SDF that causes it to error out when using Runnerv2
add e5f2f5d edit
add f78b930 Restructure processor to access beam types from downcall thread
add 4653f62 Restructure processor to access beam types from downcall thread
add 4cc68cc Restructure processor to access beam types from downcall thread
add 94b3477 use interface in logger to work around likely SLF4J bug
add cbc4c72 revert logger class
new a54d71c [BEAM-13287] Cherry pick PR #16004
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../internal/PerSubscriptionPartitionSdf.java | 32 ++++-----
.../internal/SubscriptionPartitionProcessor.java | 7 +-
.../SubscriptionPartitionProcessorImpl.java | 82 +++++++++++++++-------
.../internal/PerSubscriptionPartitionSdfTest.java | 6 +-
.../SubscriptionPartitionProcessorImplTest.java | 77 ++++++++++++--------
5 files changed, 125 insertions(+), 79 deletions(-)
[beam] 01/01: [BEAM-13287] Cherry pick PR #16004
Posted by tv...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
tvalentyn pushed a commit to branch release-2.35.0
in repository https://gitbox.apache.org/repos/asf/beam.git
commit a54d71cb0335fbc58e718806b56f14e61a31c00b
Merge: 611a8e6 cbc4c72
Author: tvalentyn <tv...@users.noreply.github.com>
AuthorDate: Thu Nov 18 16:51:36 2021 -0800
[BEAM-13287] Cherry pick PR #16004
.../internal/PerSubscriptionPartitionSdf.java | 32 ++++-----
.../internal/SubscriptionPartitionProcessor.java | 7 +-
.../SubscriptionPartitionProcessorImpl.java | 82 +++++++++++++++-------
.../internal/PerSubscriptionPartitionSdfTest.java | 6 +-
.../SubscriptionPartitionProcessorImplTest.java | 77 ++++++++++++--------
5 files changed, 125 insertions(+), 79 deletions(-)