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 e1b83ba [BEAM-8543] Fix test filtering for Dataflow Runner V2 to exclude UsesStrictTimerOrdering add 9cfcfbe [BEAM-12522] Enable side inputs on all splittable DoFn execution time related methods for portable runners. add fd4eb15 [BEAM-12522] Enable side inputs on all splittable DoFn execution time related methods. No new revisions were added by this update. Summary of changes: .../runners/core/construction/SplittableParDo.java | 79 +++++-- .../construction/SplittableParDoNaiveBounded.java | 49 ++++- ...TimeBoundedSplittableProcessElementInvoker.java | 13 +- .../core/SplittableParDoViaKeyedWorkItems.java | 74 +++++-- .../core/SplittableProcessElementInvoker.java | 5 +- ...BoundedSplittableProcessElementInvokerTest.java | 4 +- .../runners/core/SplittableParDoProcessFnTest.java | 4 +- .../SplittableProcessElementsEvaluatorFactory.java | 9 +- runners/flink/job-server/flink_job_server.gradle | 1 - .../wrappers/streaming/SplittableDoFnOperator.java | 1 + runners/google-cloud-dataflow-java/build.gradle | 1 - .../worker/SplittableProcessFnFactory.java | 4 +- runners/samza/job-server/build.gradle | 1 - .../SplittableParDoProcessKeyedElementsOp.java | 1 + runners/spark/job-server/spark_job_server.gradle | 2 - .../UsesSplittableParDoWithWindowedSideInputs.java | 28 --- .../beam/sdk/transforms/reflect/DoFnSignature.java | 7 +- .../sdk/transforms/reflect/DoFnSignatures.java | 21 +- .../beam/sdk/transforms/SplittableDoFnTest.java | 233 +++++++++++++++++---- .../reflect/DoFnSignaturesSplittableDoFnTest.java | 21 +- 20 files changed, 418 insertions(+), 140 deletions(-) delete mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesSplittableParDoWithWindowedSideInputs.java