This is an automated email from the ASF dual-hosted git repository.
amaliujia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from dc636be [BEAM-12209] Fix thread safety of DirectStreamObserver by
using atomic for message counting (#14617)
add 47cfbcb [BEAM-12127] More optimizations for
PCollectionConsumerRegistry: cache monitoring container, avoid randomInt for
sampling if resevoir is empty (#14601)
No new revisions were added by this update.
Summary of changes:
.../harness/data/PCollectionConsumerRegistry.java | 29 ++++++++++++++--------
1 file changed, 19 insertions(+), 10 deletions(-)
