This is an automated email from the ASF dual-hosted git repository.
apilloud pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 9dc1bf7 Merge pull request #12411: [BEAM-10603] Add ElementLimiters
which allows the cache to prematurely based on read elements.
add b28433c [BEAM-10470] Handle null state from waitUntilFinish
add 2f35988 Merge pull request #12441: [BEAM-10470] Handle null state
from waitUntilFinish
No new revisions were added by this update.
Summary of changes:
.../apache/beam/runners/direct/DirectRunner.java | 40 ++++++++++++----------
.../beam/runners/direct/DirectRunnerTest.java | 5 +--
2 files changed, 25 insertions(+), 20 deletions(-)