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 81cc7eb [BEAM-8133] Push ioit tests metrics to influxdb
add bef40cc [BEAM-8742] Add stateful and timely processing benchmarks
add d106f26 [BEAM-9900] Remove shutdownSourcesOnFinalWatermark flag
add c36f08a Merge pull request #11558: [BEAM-8742] Add stateful and
timely processing benchmarks
No new revisions were added by this update.
Summary of changes:
.test-infra/dataproc/init-actions/flink.sh | 2 +
.test-infra/jenkins/Docker.groovy | 3 +-
.test-infra/jenkins/LoadTestsBuilder.groovy | 9 +-
.../job_LoadTests_ParDo_Flink_Python.groovy | 139 +++++++++++++++++++--
.../job_PostCommit_Java_Nexmark_Flink.groovy | 5 -
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 1 -
runners/flink/job-server/flink_job_server.gradle | 2 -
.../runners/flink/FlinkExecutionEnvironments.java | 14 +++
.../beam/runners/flink/FlinkPipelineOptions.java | 33 ++---
.../runners/flink/FlinkPortableRunnerResult.java | 5 +-
.../FlinkStreamingPortablePipelineTranslator.java | 11 +-
.../apache/beam/runners/flink/TestFlinkRunner.java | 1 -
.../functions/ImpulseSourceFunction.java | 39 +++---
.../flink/translation/utils/CheckpointStats.java | 48 +++++++
.../wrappers/streaming/DoFnOperator.java | 27 +++-
.../streaming/io/UnboundedSourceWrapper.java | 57 ++++-----
.../flink/FlinkExecutionEnvironmentsTest.java | 36 ++++++
.../runners/flink/FlinkPipelineOptionsTest.java | 2 +-
.../flink/FlinkRequiresStableInputTest.java | 2 +-
.../beam/runners/flink/FlinkSavepointTest.java | 2 +
.../beam/runners/flink/FlinkSubmissionTest.java | 3 -
.../beam/runners/flink/PortableExecutionTest.java | 1 -
.../runners/flink/PortableStateExecutionTest.java | 1 -
.../runners/flink/PortableTimersExecutionTest.java | 1 -
.../beam/runners/flink/ReadSourcePortableTest.java | 1 -
.../flink/streaming/GroupByWithNullValuesTest.java | 1 -
.../functions/ImpulseSourceFunctionTest.java | 10 +-
.../streaming/io/UnboundedSourceWrapperTest.java | 4 +-
.../runners/portability/flink_runner_test.py | 1 -
.../apache_beam/testing/load_tests/load_test.py | 29 +++--
.../testing/load_tests/load_test_metrics_utils.py | 2 +-
.../apache_beam/testing/load_tests/pardo_test.py | 105 +++++++++++++++-
sdks/python/apache_beam/testing/test_pipeline.py | 7 +-
sdks/python/test-suites/portable/py2/build.gradle | 2 -
.../src/_includes/flink_java_pipeline_options.html | 11 +-
.../_includes/flink_python_pipeline_options.html | 11 +-
36 files changed, 491 insertions(+), 137 deletions(-)
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/utils/CheckpointStats.java
