You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2020/08/08 04:07:57 UTC
[beam] branch master updated (84cbd9b -> 56ea002)

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%)