This is an automated email from the ASF dual-hosted git repository.
amaliujia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 8122b33 [BEAM-366] Populate display data in portable job
representation (#14470)
add d502185 [BEAM-12118] Modify QueuingBeamFnDataClient to avoid
completion latency due to polling. (#14480)
No new revisions were added by this update.
Summary of changes:
.../worker/fn/data/BeamFnDataGrpcService.java | 6 +
.../sdk/fn/data/BeamFnDataInboundObserver.java | 5 +
.../data/CompletableFutureInboundDataClient.java | 6 +
.../apache/beam/sdk/fn/data/InboundDataClient.java | 3 +
.../fn/harness/control/ProcessBundleHandler.java | 5 +-
.../beam/fn/harness/data/BeamFnDataGrpcClient.java | 3 +-
.../fn/harness/data/BeamFnTimerGrpcClient.java | 5 +
.../fn/harness/data/QueueingBeamFnDataClient.java | 181 ++++++++++++++++-----
.../fn/harness/data/FakeBeamFnTimerClient.java | 6 +
.../harness/data/QueueingBeamFnDataClientTest.java | 121 +++++++++++++-
10 files changed, 296 insertions(+), 45 deletions(-)
