You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by re...@apache.org on 2020/01/22 19:01:12 UTC

[beam] branch master updated (17974cd -> dd0b001)

This is an automated email from the ASF dual-hosted git repository.

reuvenlax pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 17974cd  Merge pull request #10652: [BEAM-9168] Temporary fix for RunnerAPIPTransformHolder usage
     add dd0b001  Merge pull request #10534: Beam-2535: Support timer output timestamps in the flink runner

No new revisions were added by this update.

Summary of changes:
 .../beam/runners/core/construction/Timer.java      |  10 +-
 .../apache/beam/runners/core/SimpleDoFnRunner.java |  15 ++-
 runners/flink/flink_runner.gradle                  |   1 -
 .../wrappers/streaming/DoFnOperator.java           |  42 ++++++--
 .../streaming/ExecutableStageDoFnOperator.java     |   2 +-
 .../wrappers/streaming/SplittableDoFnOperator.java |   2 +-
 .../wrappers/streaming/WindowDoFnOperator.java     |   2 +-
 .../dataflow/worker/fn/control/TimerReceiver.java  |   4 +-
 .../worker/fn/control/TimerReceiverTest.java       |  12 ++-
 .../fnexecution/jobsubmission/JobInvocation.java   |   1 -
 .../translation/PipelineTranslatorUtils.java       |   3 +-
 .../fnexecution/control/RemoteExecutionTest.java   |  12 ++-
 .../java/org/apache/beam/sdk/transforms/DoFn.java  |   3 +
 .../org/apache/beam/sdk/transforms/ParDoTest.java  | 109 ++++++++++-----------
 .../apache/beam/fn/harness/FnApiDoFnRunner.java    |  33 ++++++-
 .../beam/fn/harness/FnApiDoFnRunnerTest.java       |  14 +--
 16 files changed, 169 insertions(+), 96 deletions(-)