This is an automated email from the ASF dual-hosted git repository.
reuvenlax pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 9f97585 [BEAM-11360] Updates Dataflow Python multi-language pipelines
to use portable job submission by default (#13536)
add 8dd9b38 [BEAM-11401][BEAM-11366] Change ReaderCache invalidations to
be asynchronous and make the timeout configurable.
add 0548643 Merge pull request #13485: [BEAM-11401][BEAM-11366] Change
ReaderCache invalidations to be async…
No new revisions were added by this update.
Summary of changes:
.../options/DataflowPipelineDebugOptions.java | 10 ++++++
.../beam/runners/dataflow/worker/ReaderCache.java | 38 +++++++++++++---------
.../dataflow/worker/StreamingDataflowWorker.java | 7 +++-
.../runners/dataflow/worker/ReaderCacheTest.java | 6 ++--
.../worker/StreamingModeExecutionContextTest.java | 3 +-
.../dataflow/worker/WorkerCustomSourcesTest.java | 2 +-
6 files changed, 44 insertions(+), 22 deletions(-)
