This is an automated email from the ASF dual-hosted git repository.
mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 72a2d04 Merge pull request #10210: Update capability matrix and spark
website pages to add details about Spark Structured Streaming Runner.
add e88377a [BEAM-8523] JobAPI: Give access to timestamped state change
history
add 2da57e7 Rename GetJobStateResponse to JobStateEvent
add 65087a6 Move state history utilities to AbstractBeamJob
add fe70233 Small bugfix to FlinkBeamJob job state mapping
add 49136e5 Fix existing bugs in AbstractJobServiceServicer
add 88cd2ed Use timestamp.Timestamp instead of float
add f8496d3 Merge pull request #9959: [BEAM-8523] JobAPI: Give access to
timestamped state change history
No new revisions were added by this update.
Summary of changes:
.../src/main/proto/beam_job_api.proto | 10 ++-
.../jobsubmission/InMemoryJobService.java | 33 ++++----
.../fnexecution/jobsubmission/JobInvocation.java | 33 ++++++--
.../portability/JobServicePipelineResult.java | 6 +-
.../portability/testing/TestJobService.java | 7 +-
.../beam/model/jobmanagement_v1/beam_job_api.pb.go | 48 +++++------
sdks/python/apache_beam/metrics/cells.py | 13 +--
.../runners/portability/abstract_job_service.py | 67 +++++++++++++--
.../portability/flink_uber_jar_job_server.py | 50 +++++++----
.../portability/flink_uber_jar_job_server_test.py | 33 +++++---
.../runners/portability/local_job_service.py | 63 +++++++-------
.../runners/portability/local_job_service_test.py | 98 ++++++++++++++++++++++
sdks/python/apache_beam/utils/proto_utils.py | 16 ++++
13 files changed, 338 insertions(+), 139 deletions(-)
create mode 100644
sdks/python/apache_beam/runners/portability/local_job_service_test.py
