This is an automated email from the ASF dual-hosted git repository. mxm pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from 6bc5f6e Merge pull request #10571 [BEAM-3713] Use unittest.SkipTest instead of nose.plugins.skip.SkipTest. add 3d541f1 [BEAM-6008] Make sure to end stream only after sending all messages and state updates add 4fc64ce Merge pull request #10583: [BEAM-6008] Make sure to end stream only after sending all messages and state updates No new revisions were added by this update. Summary of changes: .../fnexecution/jobsubmission/InMemoryJobService.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-)