This is an automated email from the ASF dual-hosted git repository.
echauchot pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from c744afd Merge pull request #4931: [BEAM-3909] Add tests for Flink
DoFnOperator side-input checkpointing
add 59108de [BEAM-3119] ensure metrics thread is shutdown
add 59f2d78 [BEAM-4088] Rebase on master, fix conflicts and adapt test to
master state.
add 022fa5f [BEAM-4088] Add a test with a real pipeline that has a DoFn
with metrics and test that it does not leak.
add 1404ff2 [BEAM-4088] Blocks until the threads in
metricsExecutorService is done, then evaluate the ThreadLeakTracker rule
new ffafc61 Merge pull request #5231 from
echauchot/BEAM-4088-fix-gradle-thread-leak
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/beam/runners/direct/DirectMetrics.java | 39 ++++---
.../apache/beam/runners/direct/DirectRunner.java | 62 ++++++-----
.../beam/runners/direct/EvaluationContext.java | 14 ++-
.../direct/ExecutorServiceParallelExecutor.java | 16 ++-
.../beam/runners/direct/DirectMetricsTest.java | 13 ++-
.../beam/runners/direct/EvaluationContextTest.java | 4 +-
.../ExecutorServiceParallelExecutorTest.java | 115 +++++++++++++++++++++
.../apache/beam/sdk/testing/ThreadLeakTracker.java | 83 +++++++++++++++
8 files changed, 293 insertions(+), 53 deletions(-)
create mode 100644
runners/direct-java/src/test/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutorTest.java
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/testing/ThreadLeakTracker.java
--
To stop receiving notification emails like this one, please contact
[email protected].
