This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 84cbd9b [BEAM-8460] Exclude category containing failing tests for
spark/flink to restore green test signal. (#12503)
add 56ea002 [BEAM-10656] Enable bundle finalization within the Java
direct runner. (#12488)
No new revisions were added by this update.
Summary of changes:
.../beam/runners/core/InMemoryBundleFinalizer.java | 53 ++++++++
...TimeBoundedSplittableProcessElementInvoker.java | 12 +-
.../apache/beam/runners/core/SimpleDoFnRunner.java | 3 +-
.../org/apache/beam/runners/core/StepContext.java | 6 +
.../runners/core/InMemoryBundleFinalizerTest.java | 32 +++--
...BoundedSplittableProcessElementInvokerTest.java | 42 +++---
.../runners/core/SplittableParDoProcessFnTest.java | 4 +-
runners/direct-java/build.gradle | 1 -
.../runners/direct/DirectExecutionContext.java | 24 ++++
.../beam/runners/direct/EvaluationContext.java | 14 ++
.../direct/GroupAlsoByWindowEvaluatorFactory.java | 1 +
.../apache/beam/runners/direct/ParDoEvaluator.java | 1 +
.../SplittableProcessElementsEvaluatorFactory.java | 3 +-
.../direct/StatefulParDoEvaluatorFactory.java | 3 +-
.../beam/runners/direct/StepTransformResult.java | 18 ++-
.../beam/runners/direct/TransformResult.java | 10 ++
.../wrappers/streaming/SplittableDoFnOperator.java | 5 +-
.../worker/SplittableProcessFnFactory.java | 6 +-
.../org/apache/beam/sdk/transforms/ParDoTest.java | 145 +++++++++++++++++++++
.../beam/sdk/transforms/SplittableDoFnTest.java | 19 ++-
20 files changed, 350 insertions(+), 52 deletions(-)
create mode 100644
runners/core-java/src/main/java/org/apache/beam/runners/core/InMemoryBundleFinalizer.java
copy
sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/windowing/AfterSynchronizedProcessingTimeTest.java
=>
runners/core-java/src/test/java/org/apache/beam/runners/core/InMemoryBundleFinalizerTest.java
(55%)
