[ https://issues.apache.org/jira/browse/BEAM-956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16140070#comment-16140070 ]
Aljoscha Krettek commented on BEAM-956: --------------------------------------- No, we still execute via {{GroupAlsoByWindowViaWindowSetNewDoFn}}: https://github.com/apache/beam/blob/ceec7ce5ba287ab40ee1f7c87129b72d4db1c1c7/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/WindowDoFnOperator.java#L104 Hi there, btw :-) > Execute ReduceFnRunner Directly in Flink Runner > ----------------------------------------------- > > Key: BEAM-956 > URL: https://issues.apache.org/jira/browse/BEAM-956 > Project: Beam > Issue Type: Improvement > Components: runner-flink > Reporter: Aljoscha Krettek > > Right now, a {{ReduceFnRunner}} is executed via > {{GroupAlsoByWindowViaWindowSetDoFn}} which in turn is executed via a > {{DoFnRunner}}. We should change that to get rid of the dependence on > {{GroupAlsoByWindowViaWindowSetDoFn}} which is an {{OldDoFn}} and also to get > rid of some unneeded layering. -- This message was sent by Atlassian JIRA (v6.4.14#64029)