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 d935b5f  Merge pull request #11432 [BEAM-9577] Small fixes to portable 
runner staging.
     add 12c66a0  [BEAM-3836] Enable dynamic splitting/checkpointing within the 
Java SDK harness. (#11448)

No new revisions were added by this update.

Summary of changes:
 .../fnexecution/control/SdkHarnessClient.java      |  10 +-
 .../fnexecution/control/RemoteExecutionTest.java   | 280 ++++++++++++++++++---
 .../beam/fn/harness/BeamFnDataReadRunner.java      |   2 +-
 .../apache/beam/fn/harness/FnApiDoFnRunner.java    |   4 +-
 .../java/org/apache/beam/fn/harness/FnHarness.java |   2 +-
 .../fn/harness/control/BundleSplitListener.java    |  14 +-
 .../fn/harness/control/ProcessBundleHandler.java   |  66 +++--
 .../beam/fn/harness/BeamFnDataReadRunnerTest.java  |   6 +-
 .../harness/control/BundleSplitListenerTest.java   |   5 +-
 .../harness/control/ProcessBundleHandlerTest.java  |   6 +
 10 files changed, 310 insertions(+), 85 deletions(-)

Reply via email to