This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 07e1f84 [BEAM-13811] Fix save_main_session arg in tests examples
(#16709)
add 18c7e2b [BEAM-13015] Calculate exception for closing
BeamFnDataInboundObserver2 statically (#16537)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/beam/sdk/fn/CancellableQueue.java | 7 ++++++-
.../beam/sdk/fn/data/BeamFnDataInboundObserver2.java | 15 ++++++++++++++-
.../java/org/apache/beam/sdk/fn/CancellableQueueTest.java | 9 +++++++++
.../beam/sdk/fn/data/BeamFnDataInboundObserver2Test.java | 6 ++----
4 files changed, 31 insertions(+), 6 deletions(-)
