This is an automated email from the ASF dual-hosted git repository.
lgajowy pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from a2b57e3 Merge pull request #9228 from ihji/BEAM-7846
add 9146b9c [BEAM-4775] Ensure each JobInvocation test is run in isolation
add f392558 [BEAM-4775] Refactor SamzaRunner - separate pipeline result
creation
add c81dd52 [BEAM-4775] Introduce PortablePipelineResult interface
add fc6cf80 [BEAM-4775] Use PortablePipelineResult in all portable runners
add e3ac1c1 [BEAM-4775] Allow reading portableMetrics from JobInvocation
using grpc calls
add ec647ee [BEAM-4775] Stash handle to pipeline result to query metrics
later
add 79fcd3b [BEAM-4775] Read portable metrics from grpc response in
Python SDK
add 5705e1f [BEAM-4775] Return portable metrics from Flink runner
add 2cfa48b Merge pull request #9020: [BEAM-4775] Support returning
metrics from job service
No new revisions were added by this update.
Summary of changes:
.../beam/runners/flink/FlinkPipelineRunner.java | 40 ++++++++++++--
.../runners/flink/FlinkPortableRunnerResult.java | 53 ++++++++++++++++++
.../jobsubmission/InMemoryJobService.java | 24 +++++++++
.../fnexecution/jobsubmission/JobInvocation.java | 33 +++++++++---
...lineRunner.java => PortablePipelineResult.java} | 15 ++++--
.../jobsubmission/PortablePipelineRunner.java | 3 +-
.../jobsubmission/JobInvocationTest.java | 62 +++++++++++++++-------
.../beam/runners/samza/SamzaPipelineRunner.java | 4 +-
.../runners/samza/SamzaPortablePipelineResult.java | 48 +++++++++++++++++
.../org/apache/beam/runners/samza/SamzaRunner.java | 16 +++---
.../beam/runners/spark/SparkPipelineResult.java | 19 +++++++
.../beam/runners/spark/SparkPipelineRunner.java | 6 ++-
.../runners/portability/portable_runner.py | 13 ++++-
13 files changed, 288 insertions(+), 48 deletions(-)
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPortableRunnerResult.java
copy
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/jobsubmission/{PortablePipelineRunner.java
=> PortablePipelineResult.java} (64%)
create mode 100644
runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPortablePipelineResult.java
