You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by re...@apache.org on 2020/12/15 22:43:59 UTC

[beam] branch master updated (9f97585 -> 0548643)

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(-)