This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 50c6d9316c8c5089065dd291b097e06b0c80980e Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> AuthorDate: Thu Jan 11 10:56:49 2018 +0100 Make parameter of DoFnRunners.lateDataDroppingRunner() more specific --- .../src/main/java/org/apache/beam/runners/core/DoFnRunners.java | 4 ++-- .../runners/flink/translation/wrappers/streaming/DoFnOperator.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java b/runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java index 9d3e25d..80c830a 100644 --- a/runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java +++ b/runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java @@ -80,12 +80,12 @@ public class DoFnRunners { public static <K, InputT, OutputT, W extends BoundedWindow> DoFnRunner<KeyedWorkItem<K, InputT>, KV<K, OutputT>> lateDataDroppingRunner( DoFnRunner<KeyedWorkItem<K, InputT>, KV<K, OutputT>> wrappedRunner, - StepContext stepContext, + TimerInternals timerInternals, WindowingStrategy<?, W> windowingStrategy) { return new LateDataDroppingDoFnRunner<>( wrappedRunner, windowingStrategy, - stepContext.timerInternals()); + timerInternals); } /** diff --git a/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java b/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java index 41a35ce..8ccbd8f 100644 --- a/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java +++ b/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java @@ -314,7 +314,7 @@ public class DoFnOperator<InputT, OutputT> doFnRunner = DoFnRunners.lateDataDroppingRunner( (DoFnRunner) doFnRunner, - stepContext, + timerInternals, windowingStrategy); } else if (keyCoder != null) { // It is a stateful DoFn -- To stop receiving notification emails like this one, please contact aljos...@apache.org.